sy-node-mysql

sy-node-mysql

a simple mysql orm

Getting Started

$ npm install sy-node-mysql --save

Example

const MySql = require('sy-node-mysql');
const config = require('./example/config.json');
const mysql = new MySql(config);


async function select() {
    const sql = `select * from db_one.person`;
    const opts = {
        where: ['id = ?'],
        params: [100]
    };
    const res = await mysql.exec(sql, opts, 'db_one', true/*readonly*/);
    return res[0];
}

select().then(data => {
    console.log(data);
});


async function update() {
    const sql = `update db_one.person`
    const opts = {
        set: ['name', 'age'],
        where: ['id = ?'],
        params: ['Tom', 18, 100]
    };
    return await mysql.exec(sql, opts, 'db_one');
}


async function insert() {
    const sql = `insert into db_one.person`
    const opts = {
        insert: ['name', 'age'],
        onUpdate: ['age'],
        params: ['Tom', 18, 18]
    };
    return await mysql.exec(sql, opts, 'db_one');
}


async function transaction() {
    const client = await mysql_client.beginTransaction('db_one');
    
    const sql1 = `update db_one.person`;
    const opts1 = {
        set: ['name', 'age'],
        where: ['id = ?'],
        params: ['Tom', 18, 100]
    };
    await mysql_client.execTransaction(sql1, opts1, client);
    
    const sql2 = `update db_one.person`;
    const opts2 = {
        set: ['name', 'age'],
        where: ['id = ?'],
        params: ['John', 16, 10]
    };
    await mysql_client.execTransaction(sql2, opts2, client);
    
    return await mysql_client.commit(client);
}