From 02fd74f6dea839f48f7ea4589393a47b27397fd9 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sun, 18 Sep 2016 10:53:16 +0800
Subject: [PATCH]

---
 src/org/redkale/source/DataDefaultSource.java | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/source/DataDefaultSource.java b/src/org/redkale/source/DataDefaultSource.java
index 089a4af78..7afdb261b 100644
--- a/src/org/redkale/source/DataDefaultSource.java
+++ b/src/org/redkale/source/DataDefaultSource.java
@@ -372,10 +372,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                         final String oldTable = info.table;
                         final String newTable = info.getTable(values[0]);
                         if (!info.tables.contains(newTable)) {
-                            Statement st = conn.createStatement();
-                            st.execute(info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable));
-                            st.close();
-                            info.tables.add(newTable);
+                            try {
+                                Statement st = conn.createStatement();
+                                st.execute(info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable));
+                                st.close();
+                                info.tables.add(newTable);
+                            } catch (SQLException sqle) { //多进程并发时可能会出现重复建表
+                                logger.log(Level.SEVERE, "create table(" + info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable) + ") error", sqle);
+                            }
                         }
                     }
                     prestmt.close();