产品动态
new sql.Database(driverName: string, dataSourceName: string) 方法。其中，driverNamedataSourceName 参数用于指定数据源。import sql from 'pts/sql';const db = new sql.Database(sql.MySQL, "user:passwd@tcp(ip:port)/database")export default function () {// 向数据库发送请求}
user:passwd@tcp(ip:port)/database?parseTime=true），避免时间解析出错。db.query(sql string) 方法，返回符合条件的数据库记录数组。其中，sql 参数代表传入的 SQL 查询语句。import sql from 'pts/sql';const db = new sql.Database(sql.MySQL, "user:passwd@tcp(ip:port)/database")export default function () {let rows = db.query("SELECT * FROM user");console.log(JSON.stringify(rows)); // [{"id":1,"name":"zhangsan","age":23},{"id":2,"name":"lisi","age":2}]}
db.exec(sql string) 方法，传入执行语句，返回本次执行对数据库的影响（返回字段包括：最后插入行的 ID、所有受影响的行数）。sql 参数代表传入的 SQL 执行语句。import sql from 'pts/sql';const db = new sql.Database(sql.MySQL, "user:passwd@tcp(ip:port)/database")export default function () {// 修改数据let result = db.exec("UPDATE user SET age=? WHERE name='zhangsan'", Math.floor(Math.random() * 100));console.log(JSON.stringify(result)); // {"lastInsertId":0,"rowsAffected":1}// 插入数据let result1 = db.exec("insert into user (name, age) values ('wanger', 18)");console.log(JSON.stringify(result)); // {"lastInsertId":66,"rowsAffected":1}}
db.exec 方法支持常见的 DDL 命令（如 create、drop、alter）和常见的 DML 命令（如 insert、update、delete）。import sql from 'pts/sql';import { sleep, check } from 'pts';const db = new sql.Database(sql.MySQL, "user:passwd@tcp(ip:port)/database")export default function () {// 查询数据let rows = db.query("SELECT * FROM user");console.log(JSON.stringify(rows)); // [{"id":1,"name":"zhangsan","age":23},{"id":2,"name":"lisi","age":2}]// 新增数据let result = db.exec("insert into user (name, age) values ('wanger', 18)");console.log(JSON.stringify(result)); // {"lastInsertId":66,"rowsAffected":1}// 删除数据let result1 = db.exec("delete from user where id > 8");console.log(JSON.stringify(result)); // {"lastInsertId":0,"rowsAffected":2}// 修改数据let result2 = db.exec("UPDATE user SET age=? WHERE name='zhangsan'", Math.floor(Math.random() * 100));console.log(JSON.stringify(result)); // {"lastInsertId":0,"rowsAffected":1}// 设置检查点check("1 row returned", () => result.rowsAffected === 1);sleep(1)}
文档反馈