util

Author: Evan Hu

…info/xiaomo/gengine/network/Session.java …nfo/xiaomo/gengine/network/ISession.javasrc/main/java/info/xiaomo/gengine/network/Session.java renamed to src/main/java/info/xiaomo/gengine/network/ISession.java src/main/java/info/xiaomo/gengine/network/Session.java renamed to src/main/java/info/xiaomo/gengine/network/ISession.java

@@ -17,7 +17,7 @@
  * desc  :
  * Copyright(©) 2017 by xiaomo.
  */
-public interface Session {
+public interface ISession {
 
     /**
      * channel

src/main/java/info/xiaomo/gengine/network/SessionKey.java

@@ -6,7 +6,7 @@
  * @author xiaomo
  */
 public class SessionKey {
-    public static final AttributeKey<Session> SESSION = AttributeKey.newInstance("SESSION");
+    public static final AttributeKey<ISession> SESSION = AttributeKey.newInstance("SESSION");
 
     public static final AttributeKey<Boolean> LOGOUT_HANDLED = AttributeKey.newInstance("LOGOUT_HANDLED");
 }

src/main/java/info/xiaomo/gengine/network/pool/MessageAndHandlerPool.java

@@ -26,7 +26,7 @@ public class MessageAndHandlerPool implements IMessageAndHandler {
     /**
      * 消息类字典
      */
-    private final Map<Integer, AbstractMessage> messages = new HashMap<>(10);
+    public final Map<Integer, AbstractMessage> messages = new HashMap<>(10);
 
     /**
      * 类和

src/main/java/info/xiaomo/gengine/network/pool/MessageRouter.java

@@ -41,15 +41,15 @@ public void consume(AbstractMessage msg, Channel channel) {
             return;
         }
 
-        Session session = AttributeUtil.get(channel, SessionKey.SESSION);
+        ISession ISession = AttributeUtil.get(channel, SessionKey.SESSION);
 
-        if (session == null) {
+        if (ISession == null) {
             return;
         }
 
         AbstractHandler handler = msgPool.getHandler(msg.getClass().getName());
         handler.setMessage(msg);
-        handler.setParam(session);
+        handler.setParam(ISession);
         log.debug("收到消息:" + msg);
 
         processor.process(handler);

src/main/java/info/xiaomo/gengine/utils/JdbcUtil.java

@@ -0,0 +1,77 @@
+package info.xiaomo.gengine.utils;
+
+
+
+import java.sql.SQLException;
+import java.util.List;
+import info.xiaomo.gengine.persist.mysql.jdbc.JdbcTemplate;
+import info.xiaomo.gengine.persist.mysql.jdbc.RowMapper;
+
+/**
+ * @author xiaomo
+ */
+public class JdbcUtil {
+
+    private static JdbcTemplate template;
+
+    public static void init(JdbcTemplate template) {
+        JdbcUtil.template = template;
+    }
+
+    public static JdbcTemplate getTemplate() {
+        return template;
+    }
+
+    public static <T> T query(String sql, RowMapper<T> mapper, Object... parameters) {
+        if (template == null) {
+            throw new RuntimeException("jdbc模板类未初始化");
+        }
+        return template.query(sql, mapper, parameters);
+    }
+
+    public static <T> List<T> queryList(String sql, RowMapper<T> mapper, Object... parameters) {
+        if (template == null) {
+            throw new RuntimeException("jdbc模板类未初始化");
+        }
+        return template.queryList(sql, mapper, parameters);
+    }
+
+    public static int update(String sql, Object... parameters) {
+        if (template == null) {
+            throw new RuntimeException("jdbc模板类未初始化");
+        }
+
+        return template.update(sql, parameters);
+    }
+
+    public static void batchUpdate(String sql, List<Object[]> parameters) {
+
+        if (template == null) {
+            throw new RuntimeException("jdbc模板类未初始化");
+        }
+        template.batchUpdate(sql, parameters);
+    }
+
+
+    /**
+     * 该表是否存在
+     *
+     * @param tableName tableName
+     * @return boolean
+     */
+    public static boolean hasTable(String tableName) {
+        try {
+            return template.hasTable(tableName);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
+
+    public static void createTable(String sql) {
+        if (template == null) {
+            throw new RuntimeException("jdbc模板类未初始化");
+        }
+        template.createTable(sql);
+    }
+}