node.js中对 mysql 进行增删改查等操做和async，await处理

时间  2019-12-17
标签 node.js node mysql 进行 增删 async await 处理 栏目 Node.js 繁體版
原文   原文链接

要对mysql进行操做，咱们须要安装一个mysql的库。php

1、安装mysql库node

npm install mysql --save

　　

2、对mysql进行简单查询操做mysql

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//链接数据库
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('链接成功');
});

//查询数据库
conn.query('select * from tb_user', function (err, data, field) {
    if (err) {
        throw err;
    }
    //data表示结果集数据，是一个数组
    console.log(data);
    data.forEach(function (value) {
        console.log(value.id, value.user_name, value.addr);
    });
    //表字段的详细信息
    console.log(field);
});

//关闭数据库链接
conn.end();

　　

2、对mysql进行增删改操做sql

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//链接数据库
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('链接成功');
});

//插入数据，query()方法能够对sql语句进行参数绑定，用?号做为占位符。
conn.query('insert into tb_user values(null, ?, ?)', ['xxx', 'xxx'], function (err, data) {
    if (err) {
        throw err;
    }
    if (data && data.affectedRows) {
        console.log('插入数据成功，id为', data.insertId);
    }
});

//修改数据
conn.query('update tb_user set user_name = ? where id = ?', ['ggg', 7], function (err, data) {
    if (err) {
        throw err;
    }
    if (data && data.affectedRows) {
        console.log('修改数据成功');
    }
});

//删除数据
conn.query('delete from tb_user where id = ?', [5], function (err, data) {
    if (err) {
        throw err;
    }
    if (data && data.affectedRows) {
        console.log('删除数据成功');
    }
});

//关闭数据库链接
conn.end();

　　

3、使用mysql链接池来优化对数据库的操做数据库

频繁的链接和断开mysql是比较消耗资源的，咱们能够建立一个链接池，复用链接池中的链接，提升效率。npm

const mysql = require('mysql');

//建立数据库链接池
let pool = mysql.createPool({
    //链接数量，默认是10
    connectionLimit: 20,
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//pool.query()方法能够自动的帮咱们在链接池中获取可用链接
pool.query('select * from tb_user', function (err, data) {
    if (err) {
        throw err;
    }
    data.forEach(function (value) {
        console.log(value.id, value.user_name, value.addr);
    });
});

//固然咱们也能够手动获取可用链接
pool.getConnection(function (err, conn) {
    if (err) {
        throw err;
    }
    conn.query('select * from `order`', function (err, data) {
        if (err) {
            throw err;
        }
        data.forEach(function (value) {
            console.log(value.id, value.order_id, value.user_id);
        });

        //链接用完以后，须要释放，从新放回链接池中。
        //注意这里并无销毁该链接，该链接仍然可用，但须要从新获取
        conn.release();
    });
});

//从链接池中获取链接时，将触发该事件
pool.on('acquire', function (conn) {
    console.log('获取链接', conn.threadId);
});

//在链接池中创建新链接时，将触发该事件
pool.on('connection', function (conn) {
    console.log('创建新链接', conn.threadId);
});

//等待可用链接时，将触发该事件
pool.on('enqueue', function () {
    console.log('等待可用链接');
});

//当链接释放回池中时，触发该事件
pool.on('release', function (conn) {
    console.log('链接被释放回池中', conn.threadId);
});

//结束池中全部的链接，否则node.js的事件循环会一直保持
setTimeout(function () {
    pool.end(function (err) {
        console.log('关闭链接池');
        console.log(err);
    });
}, 3000);

　　

4、按流的方式进行查询数组

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

let query = conn.query('select * from tb_user');
//Query类继承自Sequence，而Sequence继承自EventEmitter
//因此Query类的实例是能够监听事件

//发生错误时
query.on('error', function (err) {
    console.log(err);
});

//获取查询字段信息
query.on('fields', function (fields) {
    console.log(fields);
});

//获取查询结果
query.on('result', function (result) {
    //暂停获取结果
    conn.pause();
    //跟流的pause()和resume()很相似，控制获取数据的频率。
    setTimeout(function () {
        console.log(result);
        //恢复获取结果
        conn.resume();
    }, 1000);
});

//查询结束
query.on('end', function () {
    console.log('查询结束');
});

conn.end();

经过query.stream()方法返回一个可读流来获取数据promise

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//从一个查询中获取一个可读流
let qs = conn.query('select * from tb_user').stream({highWaterMark: 2});

let result = [];
qs.on('data', function (data) {
    result.push(data);
});

qs.on('end', function () {
    console.log('查询结束');
    console.log(result);
});

conn.end();

　　

5、mysql的事务处理async

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//链接数据库
conn.connect(function (err) {
    if (err) {
        throw err;
    }
    console.log('链接成功');
});

//开启一个事务
conn.beginTransaction(function (err) {
    if (err) {
        throw err;
    }
    conn.query('update account set money = money - 50 where name = ?', ['A'], function (err, data) {
        if (err) {
            //若是有错误则回滚
            return conn.rollback(function () {
                throw err;
            });
        }
        conn.query('update account set money = money + 50 where name = ?', ['B'], function (err, data) {
            if (err) {
                //若是有错误则回滚
                return conn.rollback(function () {
                    throw err;
                });
            }
            //提交事务
            conn.commit(function (err) {
                if (err) {
                    //若是有错误则回滚
                    return conn.rollback(function () {
                        throw err;
                    });
                }
                console.log('处理成功');
                conn.end();
            });
        });
    });
});

　　

6、解决mysql嵌套回调的问题函数

有些时候咱们的操做须要上一个操做的结果，这样会致使比较深的嵌套问题，为了解决可使用async和await来解决，而async和await又是基于promise的。

const mysql = require('mysql');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

function query(conn, sql, params = []) {
    if (!conn) {
        return;
    }
    return new Promise(function (resolve, reject) {
        conn.query(sql, params, function (err, data) {
            if (err) {
                reject(err);
            } else {
                resolve(data);
            }
        });
    });
}

(async function () {
    let result = await query(conn, 'select * from tb_user');
    console.log(result);
    let row = await query(conn, 'select * from tb_user where id = ?', [result[0].id]);
    console.log(row);
    conn.end();
})();

固然咱们还可使用 util.promiseify() 进行包装。

const mysql = require('mysql');
const util = require('util');

//建立数据库链接
let conn = mysql.createConnection({
    //主机地址
    host: '127.0.0.1',
    //用户名
    user: 'root',
    //密码
    password: '123456',
    //数据库
    database: 'test',
    //端口
    port: 3306,
    //字符集
    charset: 'utf8'
});

//注意经过util.promisify进行包装的函数，必须知足
//一、函数的最后一个参数是回调函数
//二、回调函数的参数为(err, result)，前者是错误，后者是正常结果
//注意这里不要从新建立一个变量，否则会报错。
conn.query = util.promisify(conn.query);

(async function () {
    let result = await conn.query('select * from tb_user');
    console.log(result);
    let row = await conn.query('select * from tb_user where id = ?', [result[0].id]);
    console.log(row);
    conn.end();
})();
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程