欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

nodejs进阶(6)—连接MySQL数据库示例

程序员文章站 2023-12-14 23:01:34
1. 建库连库 连接mysql数据库需要安装支持 npm install mysql 我们需要提前安装按mysql sever端 建一个数据...

1. 建库连库

连接mysql数据库需要安装支持

npm install mysql

我们需要提前安装按mysql sever端

建一个数据库mydb1

mysql> create database mydb1;
mysql> show databases;
+--------------------+
| database      |
+--------------------+
| information_schema |
| mysql       |
| mydb1       |
| performance_schema |
+--------------------+
4 rows in set (0.00 sec) 

然后建一张表user如下

create table user( 
id int not null primary key auto_increment, 
name varchar(100) not null, 
pwd varchar(100) not null,
create_date timestamp null default now()
)engine=innodb default charset=utf8; 
create unique index t_quiz_idx_0 on user(name); 

接下来我们利用nodejs连接mysql数据库

var mysql = require('mysql'); //调用mysql模块
//创建一个connection 
var connection = mysql.createconnection({   
  host: 'localhost',    //主机 
  user: 'root',        //mysql认证用户名 
  password: 'root',    //mysql认证用户密码 
  database: 'mydb1', 
  port: '3306'          //端口号 
});
//创建一个connection 
connection.connect(function(err){ 
  if(err){     
    console.log('[query] - :'+err); 
    return; 
  } 
  console.log('[connection connect] succeed!'); 
}); 
//----插入
var useraddsql = 'insert into user (name,pwd) values(?,?)';
var param = ['fff','123'];
connection.query(useraddsql,param,function(err,rs){
  if(err){
    console.log('insert err:',err.message);
    return;
  }
    console.log('insert success');
});
//执行查询 
connection.query('select * from user where id=?',[2], function(err, rs) { 
  if (err) { 
    console.log('[query] - :'+err); 
    return; 
  } 
  for(var i=0;i<rs.length;i++){
    console.log('the solution is: ', rs[i].uname); 
  }
});  

//关闭connection 
connection.end(function(err){ 
  if(err){ 
    console.log(err.tostring());
    return; 
  } 
  console.log('[connection end] succeed!'); 
});

但是实际每次创建连接都需要一定的开销,执行效率就会有影响。下面介绍一种连接池连mysql的方法:node-mysql

2. 连接池配置使用

node-mysql是目前最火的node下的mysql驱动,是mysqlpool的一个模块。

下面的代码是提供一个连接池,getpool函数返回createpool创建的数据库连接池对象。 

var mysql = require('mysql'); //调用mysql模块 
function optpool(){ 
  this.flag=true; //是否连接过 
  this.pool = mysql.createpool({   
    host: 'localhost',    //主机 
    user: 'root',        //mysql认证用户名 
    password: 'root',    //mysql认证用户密码 
    database: 'test', 
    port: '3306'          //端口号 
  }); 
 
  this.getpool=function(){ 
     return this.pool; 
  } 
}; 
module.exports = optpool;

下面的代码展示如何使用这个连接池,插入和查询的使用。需要注意的是conn.release(); //释放一个连接放回连接池 需要再操作结束后再执行,否则后面的数据库操作会报错。

var optpool = require('./models/optpool'); 
 
var optpool = new optpool(); 
var pool = optpool.getpool(); 

//执行sql语句 
//从连接池中获取一个连接
pool.getconnection(function(err,conn){ 
  //----插入 
  var useraddsql = 'insert into user (uname,pwd) values(?,?)'; 
  var param = ['eee','eee'];
  conn.query(useraddsql,param,function(err,rs){
    if(err){ 
      console.log('insert err:',err.message); 
      return; 
    } 
    console.log('insert success'); 
    //conn.release(); //放回连接池
  })
  //查询 
  conn.query('select * from user', function(err, rs) { 
    if (err) { 
      console.log('[query] - :'+err); 
      return; 
    }  
    for(var i=0;i<rs.length;i++){
      console.log(rs[i].uname); 
    }
    conn.release(); //放回连接池
  });
});

下面介绍一个复杂一点的增删查改的数据库操作,因相互之间有依赖,所以代码可读性就变得特别差。

var optpool = require('./models/optpool'); 
 
var optpool = new optpool(); 
var pool = optpool.getpool(); 

var insertsql = 'insert into table1(name,pwd) values("conan","123"),("fens.me","456")';
var selectsql = 'select * from table1 limit 10';
var deletesql = 'delete from table1';
var updatesql = 'update table1 set name="conan update" where name="conan"';

pool.getconnection(function(err,conn){ 
//delete
  conn.query(deletesql, function (err0, res0) {
    if (err0) console.log(err0);
    console.log("delete return ==> ");
    console.log(res0);

    //insert
    conn.query(insertsql, function (err1, res1) {
      if (err1) console.log(err1);
      console.log("insert return ==> ");
      console.log(res1);

      //query
      conn.query(selectsql, function (err2, rows) {
        if (err2) console.log(err2);

        console.log("select ==> ");
        for (var i in rows) {
          console.log(rows[i]);
        }

        //update
        conn.query(updatesql, function (err3, res3) {
          if (err3) console.log(err3);
          console.log("update return ==> ");
          console.log(res3);

          //query
          conn.query(selectsql, function (err4, rows2) {
            if (err4) console.log(err4);

            console.log("select ==> ");
            for (var i in rows2) {
              console.log(rows2[i]);
            }
          });
        });
      });
    });
  });
})

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

上一篇:

下一篇: