Commit 25f48c26 by ning

修改CPP路径

parent d6734c02
...@@ -29,7 +29,7 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -29,7 +29,7 @@ export default abstract class BaseTable<T> implements ITable {
Logger.info(this, '初始化数据库,[dbName=' + this.dbName + ',tableName=' + this.tableName + ']'); Logger.info(this, '初始化数据库,[dbName=' + this.dbName + ',tableName=' + this.tableName + ']');
let db = await rdb.getRdbStore(getContext(this), { let db = await rdb.getRdbStore(getContext(this), {
name: this.dbName, name: this.dbName,
securityLevel: rdb.SecurityLevel.S1 securityLevel: rdb.SecurityLevel.S4
}) })
await this.init(db); await this.init(db);
return db; return db;
...@@ -56,6 +56,9 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -56,6 +56,9 @@ export default abstract class BaseTable<T> implements ITable {
return new rdb.RdbPredicates(this.tableName) return new rdb.RdbPredicates(this.tableName)
} }
/**
* 数据新增
*/
bindToValuesBucket(bucket: ValuesBucket, item: T) { bindToValuesBucket(bucket: ValuesBucket, item: T) {
Logger.info("更新数据,bucket=", JSON.stringify(item)) Logger.info("更新数据,bucket=", JSON.stringify(item))
this.getTableColumns().forEach((col) => { this.getTableColumns().forEach((col) => {
...@@ -63,6 +66,18 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -63,6 +66,18 @@ export default abstract class BaseTable<T> implements ITable {
}) })
} }
/**
* 数据更新
*/
toUpdateBucket(bucket: ValuesBucket, item: T) {
this.getTableColumns().forEach(col => {
if (item[col]) {
bucket[col] = item[col];
}
})
}
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]
...@@ -150,7 +165,8 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -150,7 +165,8 @@ export default abstract class BaseTable<T> implements ITable {
async update(item: T, predicates?: rdb.RdbPredicates): Promise<number> { async update(item: T, predicates?: rdb.RdbPredicates): Promise<number> {
let bucket = {}; let bucket = {};
this.bindToValuesBucket(bucket, item); Logger.info(this, '更新数据,item=' + JSON.stringify(item));
this.toUpdateBucket(bucket, item);
Logger.info(this, '更新数据,bucket=' + JSON.stringify(bucket)); Logger.info(this, '更新数据,bucket=' + JSON.stringify(bucket));
bucket[this.getColumnId()] = undefined; bucket[this.getColumnId()] = undefined;
let db = await this.futureDb; let db = await this.futureDb;
...@@ -195,6 +211,7 @@ export default abstract class BaseTable<T> implements ITable { ...@@ -195,6 +211,7 @@ export default abstract class BaseTable<T> implements ITable {
return items; return items;
} }
/** /**
* 创建表的SQL语句 * 创建表的SQL语句
*/ */
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论