对象 DbConnection

DBConnection 是数据库连接的基类，用于建立和维护一个数据库连接会话。其实现了连接的基本操作，并作为派生类的基础。同时支持开始事务、提交事务、回滚事务等操作。

DBConnection 的子类包括：Odbc、MySQL、SQLite，通过实例化每个子类，我们可以很方便地访问不同种类的数据库。

DBConnection 不能直接创建，只能通过 db.open 等方法创建，例如：

1
2
var db = require("db");
var conn = db.open("mysql://root:123456@localhost:3306/test");

继承关系

成员属性

type

String, 查询当前连接数据库类型

1
readonly String DbConnection.type;

成员函数

close

关闭当前数据库连接

1
DbConnection.close() async;

---

use

选择当前数据库连接的缺省数据库

1
DbConnection.use(String dbName) async;

调用参数:

• dbName: String, 指定数据库名

---

begin

在当前数据库连接上启动一个事务

1
DbConnection.begin(String point = "") async;

调用参数:

• point: String, 指定事务的名称，缺省不指定

---

commit

提交当前数据库连接上的事务

1
DbConnection.commit(String point = "") async;

调用参数:

• point: String, 指定事务的名称，缺省不指定

---

rollback

回滚当前数据库连接上的事务

1
DbConnection.rollback(String point = "") async;

调用参数:

• point: String, 指定事务的名称，缺省不指定

---

trans

进入事务执行一个函数，并根据函数执行情况提交或者回滚

1
Boolean DbConnection.trans(Function func);

调用参数:

• func: Function, 以事务方式执行的函数

返回结果:

• Boolean, 返回事务是否提交，正常 commit 时返回 true, rollback 时返回 false，如果事务出错则抛出错误

func 执行有三种结果：

• 函数正常返回，包括运行结束和主动 return，此时事务将自动提交
• 函数返回 false，此时事务将回滚
• 函数运行错误，事务自动回滚

---

进入事务执行一个函数，并根据函数执行情况提交或者回滚

1
2
Boolean DbConnection.trans(String point,
    Function func);

调用参数:

• point: String, 指定事务的名称
• func: Function, 以事务方式执行的函数

返回结果:

• Boolean, 返回事务是否提交，正常 commit 时返回 true, rollback 时返回 false，如果事务出错则抛出错误

func 执行有三种结果：

• 函数正常返回，包括运行结束和主动 return，此时事务将自动提交
• 函数返回 false，此时事务将回滚
• 函数运行错误，事务自动回滚

---

execute

执行一个 sql 命令，并返回执行结果

1
NArray DbConnection.execute(String sql) async;

调用参数:

• sql: String, 字符串

返回结果:

• NArray, 返回包含结果记录的数组，如果请求是 UPDATE 或者 INSERT，返回结果还会包含 affected 和 insertId，mssql 不支持 insertId。

---

执行一个 sql 命令，并返回执行结果，可根据参数格式化字符串

1
2
NArray DbConnection.execute(String sql,
    ...args) async;

调用参数:

• sql: String, 格式化字符串，可选参数用 ? 指定。例如：'SELECT FROM TEST WHERE [id]=?'
• args: ..., 可选参数列表

返回结果:

• NArray, 返回包含结果记录的数组，如果请求是 UPDATE 或者 INSERT，返回结果还会包含 affected 和 insertId，mssql 不支持 insertId。

---

createTable

创建数据表

1
DbConnection.createTable(Object opts) async;

调用参数:

• opts: Object, 参数列表

---

dropTable

删除数据表

1
DbConnection.dropTable(Object opts) async;

调用参数:

• opts: Object, 参数列表

---

createIndex

创建数据表索引

1
DbConnection.createIndex(Object opts) async;

调用参数:

• opts: Object, 参数列表

---

dropIndex

删除数据表索引

1
DbConnection.dropIndex(Object opts) async;

调用参数:

• opts: Object, 参数列表

---

insert

插入新记录

1
Number DbConnection.insert(Object opts) async;

调用参数:

• opts: Object, 参数列表

返回结果:

• Number, 返回包含插入的 id，如果引擎不支持则返回 0

---

find

根据指定的条件查询数据

1
NArray DbConnection.find(Object opts) async;

调用参数:

• opts: Object, 参数列表

返回结果:

• NArray, 返回包含结果记录

---

count

根据指定的条件统计数据记录数

1
Integer DbConnection.count(Object opts) async;

调用参数:

• opts: Object, 参数列表

返回结果:

• Integer, 返回包含结果记录数

---

update

根据指定的条件更新数据

1
Integer DbConnection.update(Object opts) async;

调用参数:

• opts: Object, 参数列表

返回结果:

• Integer, 返回包含更新的记录数

---

remove

根据指定的条件删除数据

1
Integer DbConnection.remove(Object opts) async;

调用参数:

• opts: Object, 可选参数列表

返回结果:

• Integer, 返回包含更新的记录数

---

format

格式化一个 sql 命令，并返回格式化结果

1
2
String DbConnection.format(String method,
    Object opts);

调用参数:

• method: String, 指定请求的方法
• opts: Object, 可选参数列表

返回结果:

• String, 返回格式化之后的 sql 命令

---

格式化一个 sql 命令，并返回格式化结果

1
2
String DbConnection.format(String sql,
    ...args);

调用参数:

• sql: String, 格式化字符串，可选参数用 ? 指定。例如：'SELECT FROM TEST WHERE [id]=?'
• args: ..., 可选参数列表

返回结果:

• String, 返回格式化之后的 sql 命令

---

toString

返回对象的字符串表示，一般返回 "[Native Object]"，对象可以根据自己的特性重新实现

1
String DbConnection.toString();

返回结果:

• String, 返回对象的字符串表示

---

toJSON

返回对象的 JSON 格式表示，一般返回对象定义的可读属性集合

1
Value DbConnection.toJSON(String key = "");

调用参数:

• key: String, 未使用

返回结果:

• Value, 返回包含可 JSON 序列化的值