更新记录

1.0.1（2023-05-19）

[中文文档

mysqls

It is written in JavaScript,crud for mysql.You can also use transactions very easily.

mysqls 一款专为node.js生成sql语句的插件，链式调用，使用灵活。支持生成sql语法，也支持生成语法之后直接调用，支持事务等特性。 API参考很流行的ThinkPHP模型API。支持普通nodejs项目，支持unicloud,支持常用JSON函数查询 更多高级查询还未完成

技术支持群：QQ群号：826403537

安装：

下载mysql.js文件放在公共模块或者云函数云对象目录下使用 require引入即可
放在公共模块引入方式：const { Mysqls } = require("mysql")
放在云函数云对象目录下引入方式：const{ Mysqls } = require("./mysql")

mysqls参数说明

  • init: sql初始化API
  • exec: 执行sql语句
  • sql: 链式调用生成sql语句，支持生成后直接执行sql语句
  • transaction: 执行事务API

项目使用：

const { Mysqls } = require("mysql")
let sql=new Mysqls()

mysql配置初始化：

// 可在项目的启动时初始化配置
sql.init({
    host: 'localhost',
    user: 'root',
    password:'123456',
    database: 'test',
    port: 3306,
})

init 参数说明

  • ispool: 是否以连接池的方式初始化 (default:true)
  • host: host地址 (default:'127.0.0.1')
  • user: 用户名 (default:'root')
  • password: 数据库密码 (default:'root')
  • database: 使用的数据库 (default:'test')
  • port: 端口 (default:'3306')
  • waitConnection: 是否等待链接(连接池时使用) (default:true)
  • connectionLimit: 连接池大小 (default:10)
  • queueLimit: 排队限制 (default:0)

只生成sql语句案例

sql
    .table('node_table')
    .field('id,name')
    .where({id:1})
    .select()

// result
SELECT id,name FROM node_table WHERE id=1

使用exec函数执行sql语句

const sqlstr = sql
    .table('node_table')
    .field('id,name')
    .where({id:1})
    .select();

const result = await sql.exec(sqlstr);

使用sql.prototype.exec链式调用

const result = sql
    .table('node_table')
    .field('id,name')
    .where({id:1})
    .select(true)
    .exec();
  • 链式调用执行sql时select方法需要传参数:true
  • 同样适合update(true),insert(true),delet(true),query(true)方法

使用Promise方式

//使用 exec 函数
sql.exec(sql.table('web_pages').where({id:147}).select())
    .then(res=>{
        console.log(res)
    }).catch(err=>{
        console.log(err)
    })

// 使用 exec 方法
sql.table('web_pages').where({id:147}).select(true).exec()
    .then(res=>{
        console.log(res)
    }).catch(err=>{
        console.log(err)
    })

使用async/await

//使用 exec 函数
const result = await sql.exec(sql.table('web_pages').where({id:147}).select())

// 使用 exec 方法
const result = await sql.table('web_pages').where({id:147}).select(true).exec()

处理事务

const tranSqlArr = [
    sql.table('table1').data({number:'number-5'}).update(true,true),
    sql.table('table2').data({number:'number+5'}).update(true,true)
]
const result = await sql.transaction(tranSqlArr)

生成sql语句简单用法

  • 备注：sql调用方法的顺序内部已经做了排序，因此可以不按严格的sql语句顺序来写

查询

sql
    .table('node_table')
    .field('id,name')
    .where({id:1})
    .select()

SELECT id,name FROM node_table WHERE id=1

插入

sql
    .table('node_table')
    .data({name:'zane',email:'752636052@qq.com'})
    .insert()

INSERT INTO node_table (name,email) VALUES (`zane`,`752636052@qq.com`)

批量插入

let data = [
    {name:'zane',email:'752636052@qq.com'},
    {name:'zane_1',email:'752636052_1@qq.com'},
    {name:'zane_2',email:'752636052_2@qq.com'},
]
sql
    .table('node_table')
    .data(data)
    .insert()

INSERT INTO node_table (name,email) VALUES ('zane','752636052@qq.com'),('zane_1','752636052_1@qq.com'),('zane_2','752636052_2@qq.com')

更新

sql
    .table('node_table')
    .data({name:'zane',email:'752636052@qq.com'})
    .where({id:1})
    .update()

UPDATE node_table SET name=`zane`,email=`752636052@qq.com`

删除

sql .table('node_table')
    .where({name:'zane'})
    .delet();

DELETE FROM node_table WHERE name=`zane`

生成sql语句高级用法

//参数json多字段
sql
    .table('node_table')
    .where({id:1,name:'zane'})
    .select()

SELECT  * FROM node_table WHERE id=1 AND name=`zane`

//参数数组
let data=[
    {id:1,name:'zhangsan',_type:'or'},
    {sex:1,number:3}
]
sql.table('node_table').where(data).select()

SELECT * FROM node_table WHERE (id=1 OR name=`zhangsan` ) AND (sex=1 AND number=3 )

//多字段连接方式
let data=[
    {id:1,name:'zhangsan',_type:'or',_nexttype:'or'},
    {sex:1,number:3,_type:'and'}
]
sql.table('node_table').where(data).select()

SELECT * FROM node_table WHERE (id=1 OR name=`zhangsan`) OR (sex=1 AND number=3)

//表达式查询
let data={
    id:{eq:100,egt:10,_type:'or'},
    name:'zhangshan'
}
sql.table('node_table').where(data).select()

SELECT  * FROM node_table WHERE ((id=100) OR (id>=10)) AND name=`zhangshan`

//混合查询
let data=[{
    id:{eq:100,egt:10,_type:'or'},
    name:'zhangshan',
    _nexttype:'or'
},{
    status:1,
    name:{like:'%zane%'}
}]
sql.table('node_table').where(data).select()

SELECT * FROM node_table WHERE (((id=100) OR (id>=10)) AND name=`zhangshan`) OR (status=1 AND ((name LIKE `%zane%`))) 

//UNION ， UNION ALL 组合使用
sql
    .union('SELECT * FROM think_user_1',true)
    .union('SELECT * FROM think_user_2',true)
    .union(['SELECT * FROM think_user_3','SELECT name FROM think_user_4'])
    .union('SELECT * FROM think_user_5',true)
    .select()

得到
(SELECT * FROM think_user_1) UNION ALL  
(SELECT * FROM think_user_2) UNION ALL 
(SELECT * FROM think_user_3) UNION 
(SELECT name FROM think_user_4)  UNION  
(SELECT * FROM think_user_5)

更多高级查询

const mysqls = require('mysqls')
let sql = mysqls.sql
//对象数组查询写法 sql.table('shop_goods').where({goods_attribute: { JSONOBJECT: ['fid', 2179] }}).select()
//SELECT * FROM shop_goods WHERE json_contains(goods_attribute, JSON_OBJECT('fid', 2179))

//对象查询写法 sql.table('shop_goods').where({goods_attribute: { JSONEXTRACT: ['fid', 2179] }}).select()
//SELECT  * FROM shop_goods WHERE (json_extract(goods_attribute,"$.fid") = 2179 )

//一维数组查询写法 sql.table('zt_users').where({ appid: { JSONARRAY: [4, 5, 6] } }).select()
//SELECT  * FROM zt_users WHERE (json_contains(appid, json_array(4,5,6)) )

// let data = [
//  { name: '', email: '752636052@qq.com' },
//  { name: false, email: '752636052_1@qq.com' },
//  { name: true, email: '752636052_2@qq.com' },
//  { name: null, email: '752636052_2@qq.com' },
//  { name: undefined, email: '752636052_2@qq.com' },
// ]
// // let data = { name: true}
// let str = sql
//  .table('node_table')
//  .data(data)
//  .insert()
// JSON_EXTRACT(a.info,"$.name") = "Bob"
//查询是否为空可使用以下语法
// select * from shop_goods where JSON_EXTRACT(`goods_video`, '$[0]') is null;
// select * from shop_goods where json_length(`goods_video`)>0;

// let str = sql.table('zt_users').where({ appid: { JSONARRAY: [10,7] } }).select()
// console.log(str)
str = sql.table('shop_goods').where({ goods_video: { JSONEXTRACT: ['fid', '999'] } }).select()
str = sql.table('shop_goods').where({ goods_video: { JSONEXTRACT: ['fid', { isnull: true }] } }).select()//对象
str = sql.table('shop_goods').where({ goods_video: { JSONEXTRACT: ['fid', { isnull: false }] } }).select()//对象
str = sql.table('shop_goods').where({ goods_video: { JSONEXTRACT: [0, { isnull: true }] } }).select() //一维数组
str = sql.table('shop_goods').where({ goods_video: { JSONEXTRACT: [0, { isnull: false }] } }).select() //一维数组
console.log(str)
// str = sql.table('shop_goods').data({ goods_attribute: { add: 1 } }).update()
// console.log(str)
// str = sql.table('shop_goods').where({ goods_attribute: { JSONOBJECT: ['fid', 2179] } }).select()
// console.log(str)

SELECT  json_extract(goods_video,"$[0]") a FROM shop_goods WHERE (json_extract(goods_video,"$[0]") = 'https://cloud.video.taobao.com/play/u/3197438979/p/1/e/6/t/1/373106356570.mp4' )

1.0.0（2023-05-19）

创建项目

平台兼容性

阿里云 腾讯云 支付宝云
√ √ ×

云函数类插件通用教程

使用云函数类插件的前提是：使用HBuilderX 2.9+

ty-mysqls

隐私、权限声明

1. 本插件需要申请的系统权限列表：

无

2. 本插件采集的数据、发送的服务器地址、以及数据用途说明：

无

3. 本插件是否包含广告，如包含需详细说明广告表达方式、展示频率：

无

评论列表 撰写评论 向官方投诉

暂无用户评论。

插件问答 我要提问

使用中有什么不明白的地方，就向插件作者提问吧~ 我要提问

加载更多...