Commit 633299df by ning

数据库更新应用

parent 8ea3db87
...@@ -31,9 +31,9 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -31,9 +31,9 @@ export default abstract class BaseTable<T> implements ITable {
name: this.dbName, name: this.dbName,
securityLevel: rdb.SecurityLevel.S4 securityLevel: rdb.SecurityLevel.S4
}) })
Logger.info(this,"开始执行====") Logger.info(this, "开始执行====")
await this.init(db); await this.init(db);
Logger.info(this,"结束执行====") Logger.info(this, "结束执行====")
return db; return db;
} }
...@@ -80,6 +80,9 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -80,6 +80,9 @@ export default abstract class BaseTable<T> implements ITable {
} }
/**
* 更新数据的bucket
*/
toBuckets(bucket: ValuesBucket, item: T): ValuesBucket { toBuckets(bucket: ValuesBucket, item: T): ValuesBucket {
this.getTableColumns().forEach((col) => { this.getTableColumns().forEach((col) => {
bucket[col] = item[col] bucket[col] = item[col]
...@@ -163,6 +166,10 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -163,6 +166,10 @@ export default abstract class BaseTable<T> implements ITable {
return db.delete(predicates); return db.delete(predicates);
} }
/**
* 根据主键批量删除
* @param items 主键集合
*/
async deleteItems(...items: T[]): Promise<number[]> { async deleteItems(...items: T[]): Promise<number[]> {
if (!items) { if (!items) {
return []; return [];
...@@ -175,6 +182,11 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -175,6 +182,11 @@ export default abstract class BaseTable<T> implements ITable {
return results; return results;
} }
/**
* 更新对象
* @param item 要更新的对象
* @param predicates 默认不填,根据主键更新,否则依据[predicates]更新
*/
async update(item: T, predicates?: rdb.RdbPredicates): Promise<number> { async update(item: T, predicates?: rdb.RdbPredicates): Promise<number> {
let bucket = {}; let bucket = {};
Logger.info(this, '更新数据,item=' + JSON.stringify(item)); Logger.info(this, '更新数据,item=' + JSON.stringify(item));
...@@ -224,7 +236,6 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -224,7 +236,6 @@ export default abstract class BaseTable<T> implements ITable {
} }
/** /**
* 创建表的SQL语句 * 创建表的SQL语句
*/ */
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论