nodemysqlupdate_Node.js操作mysql数据库增删改查

关于node.js操作mysql数据库的相关介绍请阅读全文吧。下文介绍的非常详细&＃xff0c;具体内容如下所示&＃xff1a;

安装mysql模块 npm install mysql

数据库准备

mysql server所在的机器IP地址是192.168.0.108&＃xff0c;登录账户就用root&＃64;123456

在mysql中创建test数据库

在test数据库中创建一张users表

操作

连接数据库 var mysql&＃61;require(&＃39;mysql&＃39;);

var connection &＃61; mysql.createConnection({

host : &＃39;192.168.0.108&＃39;,

user : &＃39;root&＃39;,

password : &＃39;123456&＃39;,

database : &＃39;test1&＃39;,

port:&＃39;3306&＃39;

});

connection.connect();

插入一个user var usr&＃61;{name:&＃39;zhangsan&＃39;,password:&＃39;pwdzhangsan&＃39;,mail:&＃39;zhangsan&＃64;gmail.com&＃39;};

connection.query(&＃39;insert into users set ?&＃39;, usr, function(err, result) {

if (err) throw err;

console.log(&＃39;inserted zhangsan&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

更新user&＃xff0c;带条件 connection.query(&＃39;update users set password&＃61;"ddd" where name&＃61;"zhangsan"&＃39;, {password:&＃39;ppp&＃39;}, function(err, result) {

if (err) throw err;

console.log(&＃39;updated zhangsan\&＃39;s password to ddd&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

删除一个user&＃xff0c;带条件 connection.query(&＃39;delete from users where name&＃61;"zhangsan"&＃39;, {password:&＃39;ppp&＃39;}, function(err, result) {

if (err) throw err;

console.log(&＃39;deleted zhangsan&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

查询user&＃xff0c;所有 connection.query(&＃39;select * from users&＃39;, function(err, rows, fields) {

if (err) throw err;

console.log(&＃39;selected after deleted&＃39;);

for(var i&＃61; 0,usr;usr&＃61;rows[i&＃43;&＃43;];){

console.log(&＃39;user nae&＃61;&＃39;&＃43;usr.name &＃43; &＃39;, password&＃61;&＃39;&＃43;usr.password);

}

console.log(&＃39;\n&＃39;);

});

关闭数据库连接

connection.end();

基本的CRUD完成

mysql模块的完整功能说明参见官方&＃xff1a;

https://www.npmjs.com/package/mysql

https://github.com/felixge/node-mysql

全部demo代码 var mysql&＃61;require(&＃39;mysql&＃39;);

var connection &＃61; mysql.createConnection({

host : &＃39;192.168.0.108&＃39;,

user : &＃39;root&＃39;,

password : &＃39;123456&＃39;,

database : &＃39;test1&＃39;,

port:&＃39;3306&＃39;

});

connection.connect();

var usr&＃61;{name:&＃39;zhangsan&＃39;,password:&＃39;pwdzhangsan&＃39;,mail:&＃39;zhangsan&＃64;gmail.com&＃39;};

connection.query(&＃39;insert into users set ?&＃39;, usr, function(err, result) {

if (err) throw err;

console.log(&＃39;inserted zhangsan&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

connection.query(&＃39;select * from users&＃39;, function(err, rows, fields) {

if (err) throw err;

console.log(&＃39;selected after inserted&＃39;);

for(var i&＃61; 0,usr;usr&＃61;rows[i&＃43;&＃43;];){

console.log(&＃39;user nae&＃61;&＃39;&＃43;usr.name &＃43; &＃39;, password&＃61;&＃39;&＃43;usr.password);

}

console.log(&＃39;\n&＃39;);

});

connection.query(&＃39;update users set password&＃61;"ddd" where name&＃61;"zhangsan"&＃39;, {password:&＃39;ppp&＃39;}, function(err, result) {

if (err) throw err;

console.log(&＃39;updated zhangsan\&＃39;s password to ddd&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

connection.query(&＃39;select * from users&＃39;, function(err, rows, fields) {

if (err) throw err;

console.log(&＃39;selected after updated&＃39;);

for(var i&＃61; 0,usr;usr&＃61;rows[i&＃43;&＃43;];){

console.log(&＃39;user nae&＃61;&＃39;&＃43;usr.name &＃43; &＃39;, password&＃61;&＃39;&＃43;usr.password);

}

console.log(&＃39;\n&＃39;);

});

connection.query(&＃39;delete from users where name&＃61;"zhangsan"&＃39;, {password:&＃39;ppp&＃39;}, function(err, result) {

if (err) throw err;

console.log(&＃39;deleted zhangsan&＃39;);

console.log(result);

console.log(&＃39;\n&＃39;);

});

connection.query(&＃39;select * from users&＃39;, function(err, rows, fields) {

if (err) throw err;

console.log(&＃39;selected after deleted&＃39;);

for(var i&＃61; 0,usr;usr&＃61;rows[i&＃43;&＃43;];){

console.log(&＃39;user nae&＃61;&＃39;&＃43;usr.name &＃43; &＃39;, password&＃61;&＃39;&＃43;usr.password);

}

console.log(&＃39;\n&＃39;);

});

connection.end();