From 2451b62587b9a257914da55e1387e5a5c6b880e8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=9C=B0=E5=B9=B3=E7=BA=BF?= <22250530@qq.com>
Date: Fri, 12 Jun 2015 11:09:01 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/source/DataJDBCSource.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/com/wentch/redkale/source/DataJDBCSource.java b/src/com/wentch/redkale/source/DataJDBCSource.java
index b7fd7b28e..18b8e51bb 100644
--- a/src/com/wentch/redkale/source/DataJDBCSource.java
+++ b/src/com/wentch/redkale/source/DataJDBCSource.java
@@ -959,8 +959,10 @@ public final class DataJDBCSource implements DataSource {
             final PreparedStatement prestmt = conn.prepareStatement(sql);
             Map<K, V> rs = new LinkedHashMap<>();
             ResultSet set = prestmt.executeQuery();
+            ResultSetMetaData rsd = set.getMetaData();
+            boolean smallint = rsd.getColumnType(1) == Types.SMALLINT;
             while (set.next()) {
-                rs.put((K) set.getObject(1), (V) set.getObject(2));
+                rs.put((K) (smallint ? set.getShort(1) : set.getObject(1)), (V) set.getObject(2));
             }
             set.close();
             prestmt.close();