DataSource的clearTable、dropTable在表不存在的情况下由抛异常改为结果值返回-1

This commit is contained in:
Redkale
2019-05-28 15:51:59 +08:00
parent 2b2fd9965b
commit 6a8c86096b
2 changed files with 10 additions and 8 deletions

View File

@@ -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;

View File

@@ -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);