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

Posted 2020-08-18 白色的海

安装mysql模块

npm install mysql

 

数据库准备

mysql server所在的机器IP地址是192.168.0.108，登录账户就用root@123456

在mysql中创建test数据库

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

 

操作

连接数据库

var mysql=require(\'mysql\');

var connection = mysql.createConnection({
    host     : \'192.168.0.108\',
    user     : \'root\',
    password : \'123456\',
    database : \'test1\',
    port:\'3306\'
});

connection.connect();

 

插入一个user

var usr={name:\'zhangsan\',password:\'pwdzhangsan\',mail:\'[e-mail]\'};
connection.query(\'insert into users set ?\', usr, function(err, result) {
    if (err) throw err;

    console.log(\'inserted zhangsan\');
    console.log(result);
    console.log(\'\\n\');
});

 

更新user，带条件

connection.query(\'update users set password="ddd" where name="zhangsan"\', {password:\'ppp\'}, function(err, result) {
    if (err) throw err;

    console.log(\'updated zhangsan\\\'s password to ddd\');
    console.log(result);
    console.log(\'\\n\');
});

 

删除一个user，带条件

connection.query(\'delete from  users where name="zhangsan"\', {password:\'ppp\'}, function(err, result) {
    if (err) throw err;

    console.log(\'deleted zhangsan\');
    console.log(result);
    console.log(\'\\n\');
});

 

查询user，所有

connection.query(\'select * from users\', function(err, rows, fields) {
    if (err) throw err;

    console.log(\'selected after deleted\');
    for(var i= 0,usr;usr=rows[i++];){
        console.log(\'user nae=\'+usr.name + \', password=\'+usr.password);
    }

    console.log(\'\\n\');

});

 

关闭数据库连接

connection.end();

 

基本的CRUD完成

mysql模块的完整功能说明参见官方：

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

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

 

全部demo代码

var mysql=require(\'mysql\');

var connection = mysql.createConnection({
    host     : \'192.168.0.108\',
    user     : \'root\',
    password : \'123456\',
    database : \'test1\',
    port:\'3306\'
});

connection.connect();

var usr={name:\'zhangsan\',password:\'pwdzhangsan\',mail:\'[e-mail]\'};
connection.query(\'insert into users set ?\', usr, function(err, result) {
    if (err) throw err;

    console.log(\'inserted zhangsan\');
    console.log(result);
    console.log(\'\\n\');
});

connection.query(\'select * from users\', function(err, rows, fields) {
    if (err) throw err;

    console.log(\'selected after inserted\');
    for(var i= 0,usr;usr=rows[i++];){
        console.log(\'user nae=\'+usr.name + \', password=\'+usr.password);
    }

    console.log(\'\\n\');
});

connection.query(\'update users set password="ddd" where name="zhangsan"\', {password:\'ppp\'}, function(err, result) {
    if (err) throw err;

    console.log(\'updated zhangsan\\\'s password to ddd\');
    console.log(result);
    console.log(\'\\n\');
});

connection.query(\'select * from users\', function(err, rows, fields) {
    if (err) throw err;

    console.log(\'selected after updated\');
    for(var i= 0,usr;usr=rows[i++];){
        console.log(\'user nae=\'+usr.name + \', password=\'+usr.password);
    }

    console.log(\'\\n\');
});

connection.query(\'delete from  users where name="zhangsan"\', {password:\'ppp\'}, function(err, result) {
    if (err) throw err;

    console.log(\'deleted zhangsan\');
    console.log(result);
    console.log(\'\\n\');
});

connection.query(\'select * from users\', function(err, rows, fields) {
    if (err) throw err;

    console.log(\'selected after deleted\');
    for(var i= 0,usr;usr=rows[i++];){
        console.log(\'user nae=\'+usr.name + \', password=\'+usr.password);
    }

    console.log(\'\\n\');

});

connection.end();