MysqL = require('
MysqL'); //
调用MysqL模块
//创建一个connection
var connection =
MysqL.createConnection({
host: '192.168.3.3',//主机
user: 'root',//
MysqL认证
用户名
password: 'x5',//
MysqL认证
用户密码
database: 'dason_yu',port: '3306' //端口号
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query] - :'+err);
return;
}
console.log('[connection connect] succeed!');
});
//执行
sql语句
var userAdd
sql = 'insert into user (id,name,money) values(?,?,?)';
var param = [3,'ccc',200];
/**
* 执行所有类型的
sql 语句
* query(
sql,arr[],function)
* @parms:
sql:
sql语句 arr: 填充站位符的数组，可以缺省
* function: 回调
函数，result: 结果集，对象组成的数组
*/
connection.query(userAdd
sql,param,function(err,rs){
if(err){
console.log('insert err:',err.message);
return;
}
console.log('insert success');
});
//
关闭connection
connection.end(function(err){
if(err){
console.log(err.toString());
return;
}
console.log('[connection end] succeed!');
});
MysqL = require('
MysqL'); //用于创建
数据库连接
var pool =
MysqL.createPool({// 创建
数据库连接池
host : '127.0.0.1',user : 'root',password : 'root',database : 'dason',multipleStatements: true
});
/**
*
获取数据库连接
* @parms: err:异常 connnection：
数据库连接对象
*
*/
pool.getConnection(function(err,connection){
if(err){
console.log(err);
}
/**
* 执行所有类型的
sql 语句
* query(
sql,function)
* @parms:
sql:
sql语句 arr: 填充站位符的数组，可以缺省
* function: 回调
函数，result: 结果集，对象组成的数组
*/
connection.query('SELECT * FROM user',result){
console.log(result);
connection.release();//将连接放回连接池
});
});
