|
@@ -84,19 +84,11 @@ public void beforeUpdate(Executor executor, MappedStatement ms, Object parameter
|
|
Statement statement = CCJSqlParserUtil.parse(originalSql);
|
|
Statement statement = CCJSqlParserUtil.parse(originalSql);
|
|
if (statement instanceof Delete) {
|
|
if (statement instanceof Delete) {
|
|
Delete delete = (Delete) statement;
|
|
Delete delete = (Delete) statement;
|
|
-
|
|
|
|
// 构建 UPDATE 语句
|
|
// 构建 UPDATE 语句
|
|
Update update = new Update();
|
|
Update update = new Update();
|
|
update.setTable(delete.getTable());
|
|
update.setTable(delete.getTable());
|
|
update.setWhere(delete.getWhere());
|
|
update.setWhere(delete.getWhere());
|
|
- ArrayList<Expression> columns = new ArrayList<>();
|
|
|
|
- // 添加 SET deleted=1
|
|
|
|
- EqualsTo setDeletion = new EqualsTo();
|
|
|
|
- setDeletion.setLeftExpression(new Column("delete_flag"));
|
|
|
|
- setDeletion.setRightExpression(new LongValue(1));
|
|
|
|
- columns.add(setDeletion);
|
|
|
|
- update.setExpressions(columns);
|
|
|
|
-
|
|
|
|
|
|
+ update.addUpdateSet(new Column("delete_flag"), new LongValue(1));
|
|
PluginUtils.MPBoundSql mpBoundSql = PluginUtils.mpBoundSql(boundSql);
|
|
PluginUtils.MPBoundSql mpBoundSql = PluginUtils.mpBoundSql(boundSql);
|
|
System.out.println(update.toString());
|
|
System.out.println(update.toString());
|
|
mpBoundSql.sql(update.toString());
|
|
mpBoundSql.sql(update.toString());
|