Dbio-mysql NPM

Flision Mysql connector

##使用方法 npm install dbio-mysql

const Mysql = require('dbio-mysql');

//创建mysql实例
let mysql = new Mysql({
	host:<host>,
	port:3306,
	user:<user>
	password:<password>
	pool:true,
	logSQL:true
	});
//接收错误信息
mysql.on(Mysql.Events.Error,(err)=>console.log(err));
//接收SQL语句 必须在配置时传入logSQL:true
mysql.on(Mysql.Events.SQL,(sql)=>console.log(sql));

说明

通过mysql实例可以获取表方法，视图方法，储存过程方法，直接执行SQL方法,分别为

.table(tableName)

.view(viewName)

.proc(procName) (developing)

.execute(sql,values)

除execute方法, 其他方法都有行为触发查询。分别为

###view & table .select( fields )

###table only .insert( values )

.update( values )

.delete()

###proc only .call( values ) (developing)

##查询 .select() 会返回一个查询对象，该对象内容如下 rows 查询结果 fields 字段结构 changed_rows

where 填充对象

let result = await mysql.table('表名')
	 .where('`id`=:id',{id:1})
	 .select();
//The result will contain in rows 
let rows = result.rows

where 填充数组

let result = await mysql.table('表名')
	 .where('id=? and name=?',[1,'vincent'])
	 .select();
//The result will contain in rows 
let rows = result.rows

select 指定字段

//通过对象 不需要关心值是多少, null or undefined is ok
//here is care about keys of object only
let result = await mysql.table('表名')
	 .select({id:0,name:'xxxx'});
	 
//通过数组
let result = await mysql.table('表名')
	 .select(['id','name']);
	 
//通过字符串 注意sql注入攻击, 通过对象或数组已处理特殊字符串 但字符串没有处理
let result = await mysql.table('表名')
	 .select('id,name');

排序 .orderBy( values )

.orderBy('id desc');

.groupBy()

developing

.having()

developing

计数 .counted( enable )

.counted(true)

分页 .page( page, take )

//page 页数， take 项数量
//这里获取第1页，10项纪录
.page(1,10)

插入

let result = await mysql.table('test1')
	.insert({name:'vincent',gmt_create:new Date()}

//最后插入的id
let lst_id = result.insertId;

更新

let result = await mysql.table('test1')
	.where('id=:id',{id:1})
	.update({name:'bob'});
//改变的行数
let changedRows = result.changedRows;

删除

let result = await mysql.table('test1')
	.where('id=:id',{id:1})
	.delete();
//影响的行数
let affectedRows = result.affectedRows;

事务

let session = mysql.begin();
try{
	session.table('test1').insert(...);
	session.table('test1').where(...).update(...);
	session.table('test1').where(...).delete(...);
	session.commit();
} catch (err) {
	session.rollback();
}

##执行后保持打开默认情况下通过mysql触发的查询行为在执行完毕后连接自动释放，包括事务commit or rollback后。

如需要执行后继续使用连接必须使用session并提供keepOpen参数, 通过

let session = await mysql.session({keepOpen:true})

事务调用 .begin 已经自动创建了session, 可以通过begin的参数传入keepOpen

let session = mysql.begin({keepOpen:true});

使用完后必须手动释放

session.close();

###使用场景分页

let session = mysql.session({keepOpen:true});
//构建查询
let pick_what_i_want = session.table('test1')
	.where('bod > :bod',{bod: sometime})
	.orderBy('id desc');

//克隆查询用于查询总数
let total_items = pick_what_i_want.clone();
total_items.counted(true);

//分页
pick_what_i_want.page( 1, 10 );

//执行查询
let total_result = await total_items.select();
let items_result = await pick_what_i_want.select();

await session.close();

return {
	total: total_result.rows[0],
	items: items_result.rows,
	page: 1,
	take: 10
}

##API mysql