Commit 322895fe authored by yanzg's avatar yanzg

不记录系统日志

parent 3db07cce
...@@ -35,6 +35,8 @@ public class MessageDaoImpl extends BaseDaoImpl implements MessageDao, Initializ ...@@ -35,6 +35,8 @@ public class MessageDaoImpl extends BaseDaoImpl implements MessageDao, Initializ
" PRIMARY KEY (`MessageId`), " + " PRIMARY KEY (`MessageId`), " +
" KEY `IndexHandleTime` (`HandleTime`) " + " KEY `IndexHandleTime` (`HandleTime`) " +
") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='队列消息表'"; ") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='队列消息表'";
private static final String ALTER_TABLE_SQL = "ALTER TABLE `tbd_system`.`queue_message` " +
"MODIFY COLUMN `DedTime` bigint(0) NOT NULL DEFAULT 0 COMMENT '死信时间' AFTER `Message`";
@Override @Override
protected void init() { protected void init() {
...@@ -65,6 +67,8 @@ public class MessageDaoImpl extends BaseDaoImpl implements MessageDao, Initializ ...@@ -65,6 +67,8 @@ public class MessageDaoImpl extends BaseDaoImpl implements MessageDao, Initializ
List<MapRow> tables = this.getDb().query(MessageDaoImpl.class, "QUERY_TABLE_SQL", QUERY_TABLE_SQL); List<MapRow> tables = this.getDb().query(MessageDaoImpl.class, "QUERY_TABLE_SQL", QUERY_TABLE_SQL);
if (tables.isEmpty()) { if (tables.isEmpty()) {
this.getDb().update(MessageDaoImpl.class, "CREATE_TABLE_SQL", CREATE_TABLE_SQL); this.getDb().update(MessageDaoImpl.class, "CREATE_TABLE_SQL", CREATE_TABLE_SQL);
} else {
this.getDb().update(MessageDaoImpl.class, "ALTER_TABLE_SQL", ALTER_TABLE_SQL);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment