const MysqlHelper = require('mysql-helper-es6')
const mysqlConfig = {
    host: 'localhost',
    port: 3306,
    database: 'mydb'
    user: 'root',
    password: 123456,
    charset: 'utf8mb4'
};
const helper = MysqlHelper.getInstance(mysqlConfig);

// 第1种，promise 写法
const tableName = 'my_table';
const fields = ['name', 'age'];
const where = {id: 1};
const limit = 1;
const helper = MysqlHelper.getInstance();
helper.select(tableName, fields, where, limit)
    .then((values)=>{
        console.log(`val = ${values}`);
    }).catch((err)=>{
        console.log(err.stack);
    });
// 第2种，async / await 写法
const tableName = 'my_table';
const fields = ['name', 'age'];
const where = {id: 1};
const limit = 1;
(async () => {
    try {
        let values = await helper.select(tableName, fields, where, limit);
        console.log(`val = ${values}`);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const fields = ['name', 'age'];
// 范围查询
const where = {id: {
    '>=': 1,
    '<': 10
}};
const limit = 1;
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let values = await helper.select(tableName, fields, where, limit);
        console.log(`val = ${values}`);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const fields = ['name', 'age'];
const where = {id: 1};
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let values = await helper.selectOne(tableName, fields, where);
        console.log(`val = ${values}`);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const values = {name: 'bruce', age: 28};
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let insertId = await helper.insertInto(tableName, values);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const fieldsArr = ['name', 'age'];
const valueArr = [
    ['bruce', 28],
    ['chris', 29],
    ['doris', 30]
];
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let results = await helper.batchInsertInto(tableName, fieldsArr, valueArr);
        for (let r of results) {
            console.log('inserted id =', r.insertId);
        }
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const values = {name: 'bruce', age: 28};
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let insertId = await helper.replaceInto(tableName, values);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const values = {name: 'bruce'};
const where = {id: 1};
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let results = await helper.update(tableName, values, where);
        console.log(`res = ${results}`);
    } catch (err) {
        console.log(err.stack);
    }
})();

const tableName = 'my_table';
const where = {id: 1};
const helper = MysqlHelper.getInstance();
(async () => {
    try {
        let affectedRows = await helper.delete(tableName, where);
        console.log(`res = ${affectedRows}`);
    } catch (err) {
        console.log(err.stack);
    }
})();