nodejs连接池连接mysql数据库
node.js连接池连接数据库
1.创建项目并安装mysql和相关依赖包
$ express -e connect
$cd connect && npm install
$npm install mysql -dev
2.依赖包下载好后,在项目中加载相关依赖包
var mysql=require("mysql");
3.创建一个连接池
运用mysql模块的 createPool方法创建出一个连接池
该方法中有一个类型为对象的参数。
{
host:属性值为字符串类型,指定数据库服务器地址(可以是ip地址或主机名)默认的是localhost,
port:属性值为整数,用来指定数据库服务器的端口号 默认值是3306,
user:属性值为字符串类型,用来指定连接mysql数据库时使用的用户名,
password:属性值为字符串类型,用来指定连接mysql数据库时使用的密码,
database:属性值为字符串类型,用来设置连接的数据库的名字,
charset:属性值为字符串类型,用来设置连接字符集,属性值必须为大写字母,
debug:属性值为布尔型,用于指定是否将协议细节进行标准输出,默认值是false。
}
4.接受get请求后从连接池中获取一个连接与mysql数据库相连并进行数据库相关操作
用getConnection()方法从连接池中获取一个连接。
getConnection()方法中的回调函数有两个参数,一个用来接收错误信息,一个为成功创建出的连接对象conn。
conn对象的.query()方法用来对数据库进行相应操作,它有三个参数
第一个参数是字符串为sql语句,
第二参数为sql中用到的值 可以是一个对象也可以是一个数组
第三个参数是一个回调函数 回调函数中有两个参数,一个用来接收错误信息,一个是对库操作后返回的信息data。
完成对库操作之后需要释放连接和关闭连接池,
用conn.release();来释放连接
用pool.end()来关闭连接池