Der Inhalt dieses Artikels befasst sich mit der Bedienung und Verwendung von MySQL in NodeJS (mit Code). Ich hoffe, dass er für Freunde hilfreich ist.
npm install mysql
MySQL herunterladen und selbst installieren. Es ist ganz einfach.
Verwenden Sie das offizielle Beispiel
var mysql = require(‘mysql’);
var connection = mysql.createConnection({
host : ‘localhost’,
user : ‘me’,
password : ‘secret’,
database : ‘my_db’
});//创建mysql链接
connection.connect();
connection.query(‘SELECT 1 + 1 AS solution’, function (error, results, fields) {
if (error) throw error;
console.log(‘The solution is: ‘, results[0].solution);
});//执行sql语句
connection.end();//关闭链接Wenn Sie eine Datenbankverbindung erstellen möchten, müssen Sie zunächst die Optionen verstehen
host：主机地址 （默认：localhost） user：用户名 password：密码 port：端口号 （默认：3306） database：数据库名 charset：连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写） localAddress：此IP用于TCP连接（可选） socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略 timezone：时区（默认：’local’） connectTimeout：连接超时（默认：不限制；单位：毫秒） stringifyObjects：是否序列化对象（默认：’false’ ；与安全相关(https://github.com/felixge/node-mysql/issues/501) typeCast：是否将列值转化为本地JavaScript类型值 （默认：true） queryFormat：自定义query语句格式化方法 (https://github.com/felixge/node-mysql#custom-format) supportBigNumbers：数据库支持bigint或decimal类型列时，需要设此option为true （默认：false） bigNumberStrings：supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回（默认：false） dateStrings：强制timestamp,datetime,data类型以字符串类型返回，而不是JavaScript Date类型（默认：false） debug：开启调试（默认：false） multipleStatements：是否许一个query中有多个MySQL语句 （默认：false） flags：用于修改连接标志，更多详情：(https://github.com/felixge/node-mysql#connection-flags) ssl：使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只捆绑Amazon RDS的配置文件
Hinzufügen, Löschen, Ändern und Überprüfen werden hauptsächlich durch SQL-Anweisungen bestimmt.
var userAddSql = ‘INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)’;
var userAddSql_Params = [‘Wilson’, ‘abcd’];
connection.query(userAddSql,userAddSql_Params,function (err, result) {
…
});var userModSql = ‘DELETE FROM userinfo’;
connection.query(userModSql,function (err, result) {
…
});var userModSql = ‘UPDATE userinfo SET UserName = ?,UserPass = ? WHERE Id = ?’;
var userModSql_Params = [‘钟慰’, ‘5678’,1];
connection.query(userModSql,userModSql_Params,function (err, result) {
…
});var userGetSql = ‘SELECT * FROM userinfo’;
connection.query(userGetSql ,function (err, result) {
…
});
Die end()-Methode wird ausgeführt, nachdem die Abfragen abgeschlossen sind. Wenn vorhanden, erhält die end()-Methode eine Rückruffunktion Bei einem Fehler bei der Abfrageausführung wird die Verbindung abgebrochen. Der Fehler wird an den err-Parameter der Callback-Funktion zurückgegeben und kann in der Callback-Funktion behandelt werden!
Destory() ist relativ heftig. Es hat keine Rückruffunktion und wird sofort ausgeführt, unabhängig davon, ob die Abfrage abgeschlossen ist!
Trennung und erneute Verbindung
var mysql = require(‘mysql’);
var db_config = {
host : ‘192.168.0.200’,
user : ‘root’,
password : ‘abcd’,
port: ‘3306’,
database: ‘nodesample’
};
var connection;
function handleDisconnect() {
connection = mysql.createConnection(db_config);
connection.connect(function(err) {
if(err) {
console.log(“进行断线重连：” + new Date());
setTimeout(handleDisconnect, 2000); //2秒重连一次
return;
}
console.log(“连接成功”);
});
connection.on(‘error’, function(err) {
console.log(‘db error’, err);
if(err.code === ‘PROTOCOL_CONNECTION_LOST’) {
handleDisconnect();
} else {
throw err;
}
});
}
handleDisconnect();Der Verbindungspool wird automatisch getrennt und wieder verbunden
var mysql = require(‘mysql’);
//创建连接池
var pool = mysql.createPool({
host : ‘192.168.0.200’,
user : ‘root’,
password : ‘abcd’
});
//监听connection事件
pool.on(‘connection’, function(connection) {
connection.query(‘SET SESSION auto_increment_increment=1’);
});
连接池可以直接使用，也可以共享一个连接或管理多个连接（引用官方示例）
//直接使用
pool.query(‘SELECT 1 + 1 AS solution’, function(err, rows, fields) {
if (err) throw err;
console.log(‘The solution is: ‘, rows[0].solution);
});
//共享
pool.getConnection(function(err, connection) {
// connected! (unless err is set)
});waitForConnections
Wenn der Verbindungspool keine Verbindungen hat oder das maximale Limit überschreitet, setzen Sie ihn auf „true“ und die Verbindung wird in die Warteschlange gestellt. Setzen Sie ihn auf „false“ und es wird ein Fehler zurückgegeben ConnectionLimit-Verbindungsanzahllimit, Standard: 10
queueLimit maximales Warteschlangenlimit für Verbindungsanfragen, auf 0 gesetzt, um keine Begrenzung anzuzeigen, Standard: 0
3. Release
Aufrufen der Methode „connection.release()“. stellt die Verbindung wieder in den Verbindungspool ein und wartet auf die Verwendung durch andere Benutzer!
Andere...
so versuchen, indem Sie 'SELECT * FROM userinfo WHERE id = ' + pool.escape verwenden (' 5 OR ID = 6')
2.escapeId()
Wenn Sie der SQL-ID (Datenbankname, Tabellenname, Spaltenname) nicht vertrauen können, können Sie die Konvertierungsmethode verwenden escapeId();
Ähnlich wie 'SELECT * FROM posts ORDER BY ' + connect.escapeId("date");
Sie können MySQL verwenden. Format zum Vorbereiten von Abfrageanweisungen. Die Funktion wählt automatisch die geeignete Methode zum Escapen von Parametern.
var sql = “SELECT * FROM ? WHERE ? = ?”;
var inserts = [‘users’, ‘id’, 123];
sql = mysql.format(sql, inserts);4. Benutzerdefinierte Formatierungsfunktion
connection.config.queryFormat = function (query, values) {
if (!values) return query;
return query.replace(/:(\w+)/g, function (txt, key) {
if (values.hasOwnProperty(key)) {
return this.escape(values[key]);
}
return txt;
}.bind(this));
};
connection.query("UPDATE posts SET title = :title", { title: "Hello MySQL" });JS-Code zur Implementierung der Datenübertragung zwischen Seiten
So implementieren Sie die Funktion zum Ändern der Hautfarbe in Reac
Welche Methoden werden in jQuery häufig verwendet (mit Code)
Das obige ist der detaillierte Inhalt vonSo bedienen und verwenden Sie MySQL in NodeJS (mit Code). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
