|
@@ -28,7 +28,9 @@ class {{{ groovyClass }}} {
|
|
|
|
|
|
static def deleteItem(params) {
|
|
static def deleteItem(params) {
|
|
def d = queryDsl.delete({{{ qClassTable }}})
|
|
def d = queryDsl.delete({{{ qClassTable }}})
|
|
- {{#each deleteWheres}}.where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(params._origin.{{{ paramField }}}))){{/each}}
|
|
|
|
|
|
+ {{#each deleteWheres}}
|
|
|
|
+ .where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(params._origin.{{{ paramField }}})))
|
|
|
|
+ {{/each}}
|
|
.execute()
|
|
.execute()
|
|
return ModelOps.newSuccess(d)
|
|
return ModelOps.newSuccess(d)
|
|
}
|
|
}
|
|
@@ -41,15 +43,21 @@ class {{{ groovyClass }}} {
|
|
for (def row : params.newRows) {
|
|
for (def row : params.newRows) {
|
|
// 提取 newRows 全部新加的数据,构建insert的queryDsl语句,并添加到 "批量执行(addBatch)" 的缓存中
|
|
// 提取 newRows 全部新加的数据,构建insert的queryDsl语句,并添加到 "批量执行(addBatch)" 的缓存中
|
|
insert
|
|
insert
|
|
- {{#each insertColumns}}.setx({{{ ../qClassTable }}}.{{{ qClassField }}}, row.{{{ paramField }}}){{/each}}
|
|
|
|
|
|
+ {{#each insertColumns}}
|
|
|
|
+ .setx({{{ ../qClassTable }}}.{{{ qClassField }}}, row.{{{ paramField }}})
|
|
|
|
+ {{/each}}
|
|
.addBatch()
|
|
.addBatch()
|
|
}
|
|
}
|
|
for (def row : params.modifyRows) {
|
|
for (def row : params.modifyRows) {
|
|
// 提取 modifyRows 全部修改的数据,构建update的queryDsl语句,并添加到 "批量执行(addBatch)" 的缓存中
|
|
// 提取 modifyRows 全部修改的数据,构建update的queryDsl语句,并添加到 "批量执行(addBatch)" 的缓存中
|
|
if (row._origin.asn_in_id != null) {
|
|
if (row._origin.asn_in_id != null) {
|
|
update
|
|
update
|
|
- {{#each updateColumns}}.setx({{{ ../qClassTable }}}.{{{ qClassField }}}, row.{{{ paramField }}}){{/each}}
|
|
|
|
- {{#each updateWheres}}.where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(row._origin.{{{ paramField }}}))){{/each}}
|
|
|
|
|
|
+ {{#each updateColumns}}
|
|
|
|
+ .setx({{{ ../qClassTable }}}.{{{ qClassField }}}, row.{{{ paramField }}})
|
|
|
|
+ {{/each}}
|
|
|
|
+ {{#each updateWheres}}
|
|
|
|
+ .where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(row._origin.{{{ paramField }}})))
|
|
|
|
+ {{/each}}
|
|
.addBatch()
|
|
.addBatch()
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -57,7 +65,9 @@ class {{{ groovyClass }}} {
|
|
// 提取 removeRecords 全部删除的数据,构建删除条件,添加到 "批量执行(addBatch)" 的缓存中
|
|
// 提取 removeRecords 全部删除的数据,构建删除条件,添加到 "批量执行(addBatch)" 的缓存中
|
|
if (row._origin.asn_in_id != null) {
|
|
if (row._origin.asn_in_id != null) {
|
|
delete
|
|
delete
|
|
- {{#each deleteWheres}}.where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(row._origin.{{{ paramField }}}))){{/each}}
|
|
|
|
|
|
+ {{#each deleteWheres}}
|
|
|
|
+ .where({{{ ../qClassTable }}}.{{{ qClassField }}}.eq(DbConv.{{{ dbConvMethod }}}(row._origin.{{{ paramField }}})))
|
|
|
|
+ {{/each}}
|
|
.addBatch()
|
|
.addBatch()
|
|
}
|
|
}
|
|
}
|
|
}
|