nodejs连接池连接mysql数据库

node.js连接池连接数据库

1.创建项目并安装mysql和相关依赖包

$ express -e connect 

nodejs连接池连接mysql数据库

$cd connect && npm install

nodejs连接池连接mysql数据库

$npm install mysql -dev

nodejs连接池连接mysql数据库

2.依赖包下载好后,在项目中加载相关依赖包

var mysql=require("mysql");

3.创建一个连接池

运用mysql模块的 createPool方法创建出一个连接池

该方法中有一个类型为对象的参数。

{

host:属性值为字符串类型,指定数据库服务器地址(可以是ip地址或主机名)默认的是localhost,

 port:属性值为整数,用来指定数据库服务器的端口号 默认值是3306,

user:属性值为字符串类型,用来指定连接mysql数据库时使用的用户名,

password:属性值为字符串类型,用来指定连接mysql数据库时使用的密码,

database:属性值为字符串类型,用来设置连接的数据库的名字,

charset:属性值为字符串类型,用来设置连接字符集,属性值必须为大写字母,

debug:属性值为布尔型,用于指定是否将协议细节进行标准输出,默认值是false。

}

nodejs连接池连接mysql数据库

4.接受get请求后从连接池中获取一个连接与mysql数据库相连并进行数据库相关操作

用getConnection()方法从连接池中获取一个连接。

getConnection()方法中的回调函数有两个参数,一个用来接收错误信息,一个为成功创建出的连接对象conn。

conn对象的.query()方法用来对数据库进行相应操作,它有三个参数

第一个参数是字符串为sql语句,

第二参数为sql中用到的值 可以是一个对象也可以是一个数组

第三个参数是一个回调函数 回调函数中有两个参数,一个用来接收错误信息,一个是对库操作后返回的信息data。

nodejs连接池连接mysql数据库

完成对库操作之后需要释放连接和关闭连接池,

用conn.release();来释放连接

用pool.end()来关闭连接池