提供常用的数据库操作接口,支持Microsoft Access,Microsoft SQL Server,MySQL和SQLite数据库。
NOTE 对于联表查询时,如果多个表中具有相同的字段,那么应该指定别名而不是使用*来查询,否则在某些数据库中会报错!!
默认使用Microsoft.JET.OLEDB.4.0
连接,支持Office 97-2003(.mdb)。如果是Office 2007及以上的版本(.accdb),请手动指定驱动程序,例如:Microsoft.ACE.OLEDB.12.0
。
记得开启TCP/IP,提高访问速度。
默认使用32位5.1
版本驱动。如果是其它版本驱动程序,请手动指定驱动程序版本,例如:5.3 unicode
。
MYSQL ODBC 5.1 Driver下载: http://dev.mysql.com/get/Downloads/Connector-ODBC/5.1/mysql-connector-odbc-5.1.13-win32.msi
默认使用32位SQLite 3
驱动。
SQLite ODBC 3 Driver下载: http://www.ch-werner.de/sqliteodbc/sqliteodbc.exe
连接数据库,如果连接失败,会抛出错误信息。
options: 数据库连接设置参数(JSON),对应不同的数据库,参数略有不同。
对于Access数据库:
{
"dbType": 0, // 表示是Access类型数据库
"dbPath": "./excms.mdb", // 数据库绝对路径或相对路径
"dbUser": "", // 可选,用户名
"dbCode": "", // 可选,密码
"driver": "" // 可选,数据库连接驱动
},
对于SQL Server数据库
{
"dbType": 1, // 表示是SQL Server类型数据库
"server": ".", // 服务器地址
"dbPort": "", // 可选,服务器端口
"dbName": "excms", // 数据库名称
"dbUser": "sa", // 用户名
"dbCode": "123456" // 密码
},
对于MySQL数据库
{
"dbType": 2, // 表示是MYSQL类型数据库
"server": "localhost", // 服务器地址
"dbPort": "", // 可选,服务器端口
"dbName": "excms", // 数据库名称
"dbUser": "root", // 用户名
"dbCode": "123456", // 密码
"driver": "" // 可选,ODBC驱动版本
}
对于SQLite数据库
{
"dbType": 3, // 表示是Access类型数据库
"dbPath": "./excms.db", // 数据库绝对路径或相对路径
"driver": "" // 可选,数据库连接驱动
}
Example:
var db = require('database');
var config = {dbType: 0, dbPath: './excms.mdb'};
db.connect(config); // 返回db自身
设置要操作的表格,返回this。便于多次操作的链式写法。
tables: 表名,如果是多个表则使用数组
创建数据库,通常在虚拟主机上没有足够的权限创建。
options: 与connect相同。
创建一张数据表。
table: 表名
fields: 字段列表(array)
清除一张表中所有数据,并重置索引。该操作不可恢复,请慎用。
table: 表名
彻底删除一张表,不可恢复,请慎用。
table: 表名
添加字段。
table: 表名
fields: 字段列表(array)
删除字段。
table: 表名
fields: 字段列表(array)
查询记录,返回this。后面可跟toJSON()以JSON返回,或者rs返回原始记录集对象。
tables: 表名,如果是多个表则使用数组
fields: 字段,如果是多个字段则使用数组
where: 可选,查询条件
orders: 可选,排序字段,如果是多个字段则使用数组
top: 可选,查询记录条数
Example:
// 单表查询
var config = {
action: "select",
tables: "cms_news",
fields: ["id", "title", "posttime"],
where: "title like '菱湖%'",
orders: "id desc",
top: 4
};
var ret = db.select(config.tables, config.fields, config.where, config.orders, config.top).toJSON();
console.log(ret);
//[
// {
// "id": 107,
// "title": "菱湖早茶与渔业",
// "posttime": "2015年8月29日 7:38:37"
// }
// ,
// ...
// {
// "id": 104,
// "title": "菱湖渔业协会7点早市",
// "posttime": "2015年8月27日 7:11:24"
// }
//]
// 多表查询
var config = {
action: "select",
tables: ["cms_news as N", "cms_news_class as C"],
fields: ["N.id", "N.title", "N.posttime", "N.category", "N.poster", "C.id", "C.title as cate_title"],
where: "N.category=C.id and N.title like '菱湖%'",
orders: "N.id desc",
top: 4
};
var ret = db.select(config.tables, config.fields, config.where, config.orders, config.top).toJSON();
console.log(ret);
//[
// {
// "all": {
// "N.id": 107,
// "N.title": "菱湖早茶与渔业",
// "N.posttime": "2015年8月29日 7:38:37",
// "N.category": 5,
// "N.poster": 1,
// "C.id": 5,
// "cate_title": "要闻" // <-- 指定了别名,则使用别名
// },
// "cms_news": {
// "id": 107,
// "title": "菱湖早茶与渔业",
// "posttime": "2015年8月29日 7:38:37",
// "category": 5,
// "poster": 1
// },
// "cms_news_class": {
// "id": 5,
// "title": "要闻"
// }
// }
// ...
//]
查询记录,返回this,用于链式写法操作相同表格。后面可跟toJSON()以JSON返回,或者rs返回原始记录集对象。
获取最后一条记录的id值
id: 要查询的id字段名称
table: 要查询的表格,如果省略则使用上一次操作的表格
判断表中是否存在某字段值
where: 要查询的条件
table: 要查询的表格,如果省略则使用上一次操作的表格
插入记录,返回this。后面可跟ar返回受影响的行数,或者id返回新记录的id值。
tables: 表名,如果是多个表则使用数组
fields: 字段,如果是多个字段则使用JSON
插入记录,返回this,用于链式写法操作相同表格。后面可跟ar返回受影响的行数,或者id返回新记录的id值。
更新记录,返回this。后面可跟ar返回受影响的行数。
tables: 表名,如果是多个表则使用数组
fields: 字段,如果是多个字段则使用JSON
where: 可选,查询条件
更新记录,返回this,用于链式写法操作相同表格。后面可跟ar返回受影响的行数。
删除记录,返回this。后面可跟ar返回受影响的行数。
tables: 表名,如果是多个表则使用数组
fields: 字段,如果是多个字段则使用数组
where: 可选,查询条件
orders: 可选,排序字段,如果是多个字段则使用数组
top: 可选,查询记录条数
删除记录,返回this,用于链式写法操作相同表格。后面可跟ar返回受影响的行数。
执行SQL语句,返回记录集(this.rs)或受影响的行数(this.ar)或者插入记录的索引(this.id)。
sql: 要执行的sql语句(access语法),为了兼容多种数据库,sql语句中的字符串全部需要使用'包围。
分页查询,可以是单表、多表连接或者包含子查询的复杂SQL查询语句。
将记录集结果转为JSON。如果给了index参数,则返回对应索引的JSON;如果未给定index参数,则返回数组;如果无结果,则返回false。
如果是多表查询,且查询语句中包含*,请使用toArray()方法返回结果。
Example:
var ret1 = db.runsql('select top 10 * from users').toJSON();
ret1.forEach(function(item){
console.log(item.username);
})
var ret2 = db.runsql('select * from users where id=1').toJSON(0);
console.log(ret2);
// 其它示例请查看select()方法
将记录集结果转为Array。如果给了index参数,则返回对应索引的数组;如果未给定index参数,则返回整个结果数组;如果没有查询到记录,则返回空数组。
循环处理查询得到记录集。
db.runsql('select top 10 * from users');
db.forEach(function(value, name, rowIndex, colIndex) {
console.log(value, name, rowIndex, colIndex);
});
将Access的语句转换为Mssql/Mysql的语句。
sql: 原始的sql语句(access语法),为了兼容多种数据库,sql语句中的字符串全部需要使用'包围。
Example:
var sql = "select top 10 * from [users]";
sql = db.resolveSQL(sql);
console.log(sql);
// prints:
// select * from `users` limit 10
根据当前连接的数据库类型,生成SQL语句。该方法对于复杂的SQL语句无力,请直接使用runsql方法。
action: 执行方法,[select, delete, update, insert]
tables: 表名,如果是多个表则使用数组
fields: 字段,如果是多个字段则使用数组(select, delete)或JSON(update, insert)
where: 可选,查询条件
orders: 可选,排序字段,如果是多个字段则使用数组
top: 可选,查询记录条数
Example:
var config = {
action: "select",
tables: ["cms_news as N", "cms_news_class as C"],
fields: ["N.id", "N.title", "N.posttime", "N.category", "N.poster", "C.id", "C.title"],
where: "N.category=C.id and N.title like '菱湖%'",
orders: "N.id desc",
top: 4
};
var db = require("database");
db.options = {};
db.options.dbType = 0;
var sql1 = db.produceSQL(config.action, config.tables, config.fields, config.where, config.orders, config.top);
console.log(sql1);
// prints:
// select top 4 N.id,N.title,N.posttime,N.category,N.poster,C.id,C.title from cms_news as N,cms_news_class as C where N.category=C.id and N.title like '菱湖%' order by N.id desc
db.options.dbType = 2;
var sql2 = db.produceSQL(config.action, config.tables, config.fields, config.where, config.orders, config.top);
console.log(sql2);
// prints:
// select N.id,N.title,N.posttime,N.category,N.poster,C.id,C.title from cms_news as N,cms_news_class as C where N.category=C.id and N.title like '菱湖%' order by N.id desc limit 4
遍历数据库,返回所有表名及其中字段信息。
Example:
var tables = db.getTables();
console.log(tables);
/* prints like bellow:
{
"users": {
"id": {
Name: "id",
Type: 0,
Status: 0,
DefinedSize: 4
}
}
}
*/
返回表中字段信息
table: 表名,如果不指定则使用上一次操作的表格
获取数据库的版本号,例如:Microsoft SQL Server 2008 R2 Service Pack 2。
原始的数据库连接参数对象。
当前的数据库连接对象。
当前的记录集(RecordSet)。
受影响的行数(Affected rows)。
插入数据后的id值
支持的数据库类型的代号。
通用字段类型。为了兼容所有数据库,在创建表的时候,请使用通用字段类型。
数据表字段类型代号。