修改实体位置

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/QueueServerTokenDaoImpl.java

 package com.yanzuoguang.mq.dao.impl;
 
 import com.yanzuoguang.dao.impl.BaseDaoImpl;
-import com.yanzuoguang.db.DbExecute;
 import com.yanzuoguang.mq.dao.QueueServerTokenDao;
 import com.yanzuoguang.mq.vo.QueueServerTokenVo;
 import com.yanzuoguang.util.vo.MapRow;
+import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
@@ -15,7 +15,7 @@ import java.util.List;
  * @author 颜佐光
  */
 @Component
-public class QueueServerTokenDaoImpl extends BaseDaoImpl implements QueueServerTokenDao {
+public class QueueServerTokenDaoImpl extends BaseDaoImpl implements QueueServerTokenDao, InitializingBean {
     private static final String QUERY_TABLE_SQL = "SHOW TABLES LIKE 'queue_servertoken'";
     private static final String CREATE_TABLE_SQL = "CREATE TABLE `queue_servertoken` (" +
             "  `serverTokenId` varchar(32) NOT NULL COMMENT '编号'," +
@@ -36,11 +36,21 @@ public class QueueServerTokenDaoImpl extends BaseDaoImpl implements QueueServerT
         register(QueueServerTokenVo.class);
     }
 
+    /**
+     * Invoked by a BeanFactory after it has set all bean properties supplied
+     * (and satisfied BeanFactoryAware and ApplicationContextAware).
+     * <p>This method allows the bean instance to perform initialization only
+     * possible when all bean properties have been set and to throw an
+     * exception in the event of misconfiguration.
+     *
+     * @throws Exception in the event of misconfiguration (such
+     *                   as failure to set an essential property) or if initialization fails.
+     */
     @Override
-    protected void initExecute(DbExecute db) {
-        List<MapRow> tables = db.query(QueueServerTokenDaoImpl.class, "QUERY_TABLE_SQL", QUERY_TABLE_SQL);
+    public void afterPropertiesSet() throws Exception {
+        List<MapRow> tables = this.getDb().query(QueueServerTokenDaoImpl.class, "QUERY_TABLE_SQL", QUERY_TABLE_SQL);
         if (tables.isEmpty()) {
-            db.update(QueueServerTokenDaoImpl.class, "CREATE_TABLE_SQL", CREATE_TABLE_SQL);
+            this.getDb().update(QueueServerTokenDaoImpl.class, "CREATE_TABLE_SQL", CREATE_TABLE_SQL);
         }
     }
 }