用户 (默认为早前的一个).新用户的新密码 (默认为早前的一个).数据库名称 (默认为早前的一个).
6、处理服务器连接断开
MysqL.createConnection(db_config); // Recreate the connection,since
// the old one cannot be reused.
connection.connect(function(err) { // The server is either down
if(err) { // or restarting (takes a while sometimes).
console.log('error when connecting to db:',err);
setTimeout(handleDisconnect,2000); // We introduce a delay before attempting to reconnect,} // to avoid a hot loop,and to allow our node script to
}); // process asynchronous requests in the meantime.
// If you're also serving http,display a 503 error.
connection.on('error',function(err) {
console.log('db error',err);
if(err.code === 'PROTOCOL_CONNECTION_LOST') { // Connection to the
MysqL server is usually
handleDisconnect(); // lost due to either server restart,or a
} else { // connnection idle timeout (the wait_timeout
throw err; // server variable configures this)
}
});
}
handleDisconnect();
7、转义查询值
为了避免sql注入攻击，需要转义用户提交的数据。可以使用connection.escape() 或者 pool.escape()
例如：
sql = 'SELECT * FROM users WHERE id = ' + connection.escape(userId);
connection.query(
sql,function(err,results) {
// ...
});
或者使用？作为占位符
不同类型值的转换结果
['a','b'] 转换为 'a','b'
嵌套数组 [['a','b'],['c','d']] 转换为 ('a','b'),('c','d')
Objects 转换为 key = 'val' pairs. 嵌套对象转换为字符串.
undefined / null ===> NULL
NaN / Infinity 不变. MysqL 不支持这些值,除非有工具支持，否则插入这些值会引起错误.
转换实例：
MysqL'};
var query = connection.query('INSERT INTO posts SET ?',post,result) {
// Neat!
});
console.log(query.
sql); // INSERT INTO posts SET `id` = 1,`title` = 'Hello
MysqL'
或者手动转换
MysqL.escape("Hello
MysqL");
console.log(query); // SELECT * FROM posts WHERE title='Hello
MysqL'
8、转换查询标识符
如果不能信任sql标识符(数据库名、表名、列名)，可以使用转换方法MysqL.escapeId(identifier)；
MysqL.escapeId(sorter);
console.log(query); // SELECT * FROM posts ORDER BY `date`
支持转义多个
MysqL.escapeId('posts.' + sorter);
console.log(query); // SELECT * FROM posts ORDER BY `posts`.`date`
可以使用??作为标识符的占位符
sql); // SELECT `username`,`email` FROM `users` WHERE id = 1
可以使用MysqL.format来准备查询语句，该函数会自动的选择合适的方法转义参数。
sql = "SELECT * FROM ?? WHERE ?? = ?";
var inserts = ['users','id',userId];
sql =
MysqL.format(
sql,inserts);
MysqL" });
11、获取插入行的id
当使用自增主键时获取插入行id，如：
12、流处理
有时你希望选择大量的行并且希望在数据到达时就处理他们，你就可以使用这个方法
13、混合查询语句（多语句查询）
因为混合查询容易被sql注入攻击，默认是不允许的，可以使用：
MysqL.createConnection({multipleStatements: true});
开启该功能。
混合查询实例：
同样可以使用流处理混合查询结果：
如果其中一个查询语句出错，Error对象会包含err.index指示错误语句的id，整个查询也会终止。
混合查询结果的流处理方式是做实验性的，不稳定。
14、事务处理
connection级别的简单事务处理
15、错误处理
boolean
更详细的说明请查看：https://github.com/felixge/node-MysqL
希望本文所述对大家nodejs程序设计有所帮助。
