地址:https://github.com/fmfe/lib-sqlInstallation$npminstall@fmfe/lib-sqlor$yarnadd@fmfe/lib-sqlUsage传入配置信息有两种方式:使用config来管理我们的配置文件.假设我们的项目目录下有一个config目录,config目录下有一个dev.json文件.config/dev.json{"mysql":{"host":"127.0.0.1","port":3306,"数据库”:“测试”,“用户”:“root”,“密码”:“123456”},“mssql”:{“用户”:“sa”,“密码”:“123456”,“服务器”:“127.0.0.1","database":"test","port":1433,"pool":{"min":0,"max":10,"idleTimeoutMillis":3000}}}mysql.jsconst{mysql}=require('@fmfe/lib-sql');constmysqlPool=mysql.init();const_getNewSqlParamEntity=mysql._getNewSqlParamEntity;//执行一条sql语句//mysql.exec(mysqlPool,sql,params);asyncfunctionexec(){constsql1='select*from??限制2';constdata=awaitmysql.exec(mysqlPool,sql1,['tbl_user']);}//执行mysql事务,可以多次递增/delete/modifysql语句//mysql.exectrans(mysqlpool,sqlParamsEntity);异步函数execTrans(){constsqlParamsEntity=[];constsql1='插入到??(姓名,年龄,性别)值(?,?,?)';constparam1=['tbl_user','aaa',20,1];sqlParamsEntity.push(_getNewSqlParamEntity(sql1,param1));constsql2='插入到??(姓名,年龄,性别)值(?,?,?)';constparam2=['tbl_user','bbb',22,0];sqlParamsEntity.push(_getNewSqlParamEntity(sql2,param2));constsql3='更新??设置年龄=?其中id=?';constparam3=['tbl_user',10,1];sqlParamsEntity.push(_getNewSqlParamEntity(sql3,param3));//....constdata=awaitmysql.execTrans(mysqlPool,sqlParamsEntity);}mssql.jsconst{mssql}=require('@fmfe/lib-sql');const_getNewSqlParamEntity=mssql._getNewSqlParamEntity;//执行单条语句//mssql.exec(sql)asyncfunctionexec(){constsql1='从tbl_userorderbyagedesc中选择Top3name,age,sex';常量数据=等待mssql.exec(sql1);}//执行sqlserver事务,最好执行add/delete/modify语句,这里只是使用select的演示//mssql.exectrans(sqlParamsEntity);异步函数exectrans(){constsqlParamsEntity=[];constsql1='select*fromtbl_userwhereid=1';sqlParamsEntity.push(_getNewSqlParamEntity(sql1));constsql2='select*fromtbl_userwhereid=2';sqlParamsEntity.push(_getNewSqlParamEntity(sql2));//...constdata=awaitmssql.execTrans(sqlParamsEntity);由于配置文件是由config管理的,所以在运行项目时可以使用命令:NODE_ENV=devnode...,@fmfe/lib-sql自动获取数据库的相关配置。通过传入配置文件来调用库。我们参考上面的代码示例,只需要做一点改动:mysql.js只需要在初始化时传入mysql数据库配置即可。const{mysql}=require('@fmfe/lib-sql');constmysqlPool=mysql.init({host:'127.0.0.1',port:3306,database:'test',user:'root',password:'123456'});......mssql.js通过在配置中const{mssql}=require('@fmfe/lib-sql');constconfig={用户:'sa',密码:'123456',服务器:'127.0.0.1',数据库:'test',端口:1433,池:{min:0,max:10,idleTimeoutMillis:3000}}asyncfunctionexec(){......constdata=awaitmssql.exec(sql1,config);}asyncfunctionexectrans(){......constdata=awaitmssql.execTrans(sqlParamsEntity,config);}
