From 6a8c86096b5dca0de75e4bd0527025b6e8696a7f Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Tue, 28 May 2019 15:51:59 +0800
Subject: [PATCH] =?UTF-8?q?DataSource=E7=9A=84clearTable=E3=80=81dropTable?=
 =?UTF-8?q?=E5=9C=A8=E8=A1=A8=E4=B8=8D=E5=AD=98=E5=9C=A8=E7=9A=84=E6=83=85?=
 =?UTF-8?q?=E5=86=B5=E4=B8=8B=E7=94=B1=E6=8A=9B=E5=BC=82=E5=B8=B8=E6=94=B9?=
 =?UTF-8?q?=E4=B8=BA=E7=BB=93=E6=9E=9C=E5=80=BC=E8=BF=94=E5=9B=9E-1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/source/DataJdbcSource.java |  2 ++
 src/org/redkale/source/DataSource.java     | 16 ++++++++--------
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index c4d8d444d..08239c6e4 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -230,6 +230,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             stmt.close();
             return CompletableFuture.completedFuture(c);
         } catch (SQLException e) {
+            if (info.isTableNotExist(e)) return CompletableFuture.completedFuture(-1);
             CompletableFuture future = new CompletableFuture();
             future.completeExceptionally(e);
             return future;
@@ -250,6 +251,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             stmt.close();
             return CompletableFuture.completedFuture(c);
         } catch (SQLException e) {
+            if (info.isTableNotExist(e)) return CompletableFuture.completedFuture(-1);
             CompletableFuture future = new CompletableFuture();
             future.completeExceptionally(e);
             return future;
diff --git a/src/org/redkale/source/DataSource.java b/src/org/redkale/source/DataSource.java
index b17e8545d..df2805398 100644
--- a/src/org/redkale/source/DataSource.java
+++ b/src/org/redkale/source/DataSource.java
@@ -216,7 +216,7 @@ public interface DataSource {
      * @param <T>   Entity泛型
      * @param clazz Entity类
      *
-     * @return 影响的记录条数
+     * @return 影响的记录条数 -1表示表不存在
      */
     public <T> int clearTable(final Class<T> clazz);
 
@@ -227,7 +227,7 @@ public interface DataSource {
      * @param <T>   Entity泛型
      * @param clazz Entity类
      *
-     * @return 影响的记录条数CompletableFuture
+     * @return 影响的记录条数CompletableFuture -1表示表不存在
      */
     public <T> CompletableFuture<Integer> clearTableAsync(final Class<T> clazz);
 
@@ -239,7 +239,7 @@ public interface DataSource {
      * @param clazz Entity类
      * @param node  过滤条件
      *
-     * @return 影响的记录条数
+     * @return 影响的记录条数 -1表示表不存在
      */
     public <T> int clearTable(final Class<T> clazz, final FilterNode node);
 
@@ -251,7 +251,7 @@ public interface DataSource {
      * @param clazz Entity类
      * @param node  过滤条件
      *
-     * @return 影响的记录条数CompletableFuture
+     * @return 影响的记录条数CompletableFuture -1表示表不存在
      */
     public <T> CompletableFuture<Integer> clearTableAsync(final Class<T> clazz, final FilterNode node);
 
@@ -263,7 +263,7 @@ public interface DataSource {
      * @param <T>   Entity泛型
      * @param clazz Entity类
      *
-     * @return 影响的记录条数
+     * @return 影响的记录条数 -1表示表不存在
      */
     public <T> int dropTable(final Class<T> clazz);
 
@@ -274,7 +274,7 @@ public interface DataSource {
      * @param <T>   Entity泛型
      * @param clazz Entity类
      *
-     * @return 影响的记录条数CompletableFuture
+     * @return 影响的记录条数CompletableFuture -1表示表不存在
      */
     public <T> CompletableFuture<Integer> dropTableAsync(final Class<T> clazz);
 
@@ -286,7 +286,7 @@ public interface DataSource {
      * @param clazz Entity类
      * @param node  过滤条件
      *
-     * @return 影响的记录条数
+     * @return 影响的记录条数 -1表示表不存在
      */
     public <T> int dropTable(final Class<T> clazz, final FilterNode node);
 
@@ -298,7 +298,7 @@ public interface DataSource {
      * @param clazz Entity类
      * @param node  过滤条件
      *
-     * @return 影响的记录条数CompletableFuture
+     * @return 影响的记录条数CompletableFuture -1表示表不存在
      */
     public <T> CompletableFuture<Integer> dropTableAsync(final Class<T> clazz, final FilterNode node);