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 { 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 { 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 Entity泛型 * @param clazz Entity类 * - * @return 影响的记录条数 + * @return 影响的记录条数 -1表示表不存在 */ public int clearTable(final Class clazz); @@ -227,7 +227,7 @@ public interface DataSource { * @param Entity泛型 * @param clazz Entity类 * - * @return 影响的记录条数CompletableFuture + * @return 影响的记录条数CompletableFuture -1表示表不存在 */ public CompletableFuture clearTableAsync(final Class clazz); @@ -239,7 +239,7 @@ public interface DataSource { * @param clazz Entity类 * @param node 过滤条件 * - * @return 影响的记录条数 + * @return 影响的记录条数 -1表示表不存在 */ public int clearTable(final Class clazz, final FilterNode node); @@ -251,7 +251,7 @@ public interface DataSource { * @param clazz Entity类 * @param node 过滤条件 * - * @return 影响的记录条数CompletableFuture + * @return 影响的记录条数CompletableFuture -1表示表不存在 */ public CompletableFuture clearTableAsync(final Class clazz, final FilterNode node); @@ -263,7 +263,7 @@ public interface DataSource { * @param Entity泛型 * @param clazz Entity类 * - * @return 影响的记录条数 + * @return 影响的记录条数 -1表示表不存在 */ public int dropTable(final Class clazz); @@ -274,7 +274,7 @@ public interface DataSource { * @param Entity泛型 * @param clazz Entity类 * - * @return 影响的记录条数CompletableFuture + * @return 影响的记录条数CompletableFuture -1表示表不存在 */ public CompletableFuture dropTableAsync(final Class clazz); @@ -286,7 +286,7 @@ public interface DataSource { * @param clazz Entity类 * @param node 过滤条件 * - * @return 影响的记录条数 + * @return 影响的记录条数 -1表示表不存在 */ public int dropTable(final Class clazz, final FilterNode node); @@ -298,7 +298,7 @@ public interface DataSource { * @param clazz Entity类 * @param node 过滤条件 * - * @return 影响的记录条数CompletableFuture + * @return 影响的记录条数CompletableFuture -1表示表不存在 */ public CompletableFuture dropTableAsync(final Class clazz, final FilterNode node);