mysql-helper-es6

mysql 帮助类，用 es2017 语法编写

在 Node.js v8.x 运行良好

• 如果需要 ts 版本，可以看看 ts-mysql-helper

Usage

初始化

1const MysqlHelper = require('mysql-helper-es6')
2const mysqlConfig = {
3    host: 'localhost',
4    port: 3306,
5    database: 'mydb'
6    user: 'root',
7    password: 123456,
8    charset: 'utf8mb4'
9};
10const helper = MysqlHelper.getInstance(mysqlConfig);

查询多条数据

1// 第1种，promise 写法
2const tableName = 'my_table';
3const fields = ['name', 'age'];
4const where = {id: 1};
5const limit = 1;
6const helper = MysqlHelper.getInstance();
7helper.select(tableName, fields, where, limit)
8    .then((values)=>{
9        console.log(`val = ${values}`);
10    }).catch((err)=>{
11        console.log(err.stack);
12    });
13// 第2种，async / await 写法
14const tableName = 'my_table';
15const fields = ['name', 'age'];
16const where = {id: 1};
17const limit = 1;
18(async () => {
19    try {
20        let values = await helper.select(tableName, fields, where, limit);
21        console.log(`val = ${values}`);
22    } catch (err) {
23        console.log(err.stack);
24    }
25})();

更复杂的查询

1const tableName = 'my_table';
2const fields = ['name', 'age'];
3// 范围查询
4const where = {id: {
5    '>=': 1,
6    '<': 10
7}};
8const limit = 1;
9const helper = MysqlHelper.getInstance();
10(async () => {
11    try {
12        let values = await helper.select(tableName, fields, where, limit);
13        console.log(`val = ${values}`);
14    } catch (err) {
15        console.log(err.stack);
16    }
17})();

查询一条数据

1const tableName = 'my_table';
2const fields = ['name', 'age'];
3const where = {id: 1};
4const helper = MysqlHelper.getInstance();
5(async () => {
6    try {
7        let values = await helper.selectOne(tableName, fields, where);
8        console.log(`val = ${values}`);
9    } catch (err) {
10        console.log(err.stack);
11    }
12})();

插入数据

1const tableName = 'my_table';
2const values = {name: 'bruce', age: 28};
3const helper = MysqlHelper.getInstance();
4(async () => {
5    try {
6        let insertId = await helper.insertInto(tableName, values);
7    } catch (err) {
8        console.log(err.stack);
9    }
10})();
11

批量插入数据

1const tableName = 'my_table';
2const fieldsArr = ['name', 'age'];
3const valueArr = [
4    ['bruce', 28],
5    ['chris', 29],
6    ['doris', 30]
7];
8const helper = MysqlHelper.getInstance();
9(async () => {
10    try {
11        let results = await helper.batchInsertInto(tableName, fieldsArr, valueArr);
12        for (let r of results) {
13            console.log('inserted id =', r.insertId);
14        }
15    } catch (err) {
16        console.log(err.stack);
17    }
18})();

插入或更新数据

1const tableName = 'my_table';
2const values = {name: 'bruce', age: 28};
3const helper = MysqlHelper.getInstance();
4(async () => {
5    try {
6        let insertId = await helper.replaceInto(tableName, values);
7    } catch (err) {
8        console.log(err.stack);
9    }
10})();

更新数据

1const tableName = 'my_table';
2const values = {name: 'bruce'};
3const where = {id: 1};
4const helper = MysqlHelper.getInstance();
5(async () => {
6    try {
7        let results = await helper.update(tableName, values, where);
8        console.log(`res = ${results}`);
9    } catch (err) {
10        console.log(err.stack);
11    }
12})();

删除数据

1const tableName = 'my_table';
2const where = {id: 1};
3const helper = MysqlHelper.getInstance();
4(async () => {
5    try {
6        let affectedRows = await helper.delete(tableName, where);
7        console.log(`res = ${affectedRows}`);
8    } catch (err) {
9        console.log(err.stack);
10    }
11})();