optimize: support oracle on delete tccfence logs

tcc/src/main/java/io/seata/rm/tcc/TCCFenceHandler.java

@@ -17,6 +17,7 @@
 
 import java.lang.reflect.Method;
 import java.sql.Connection;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.Set;
@@ -294,6 +295,12 @@ public static int deleteFenceByDate(Date datetime) {
         int total = 0;
         try {
             connection = DataSourceUtils.getConnection(dataSource);
+            if(isOracle(connection)){
+                //delete by date if DB is oracle
+                return TCC_FENCE_DAO.deleteTCCFenceDOByDate(connection, datetime);
+            }
+
+            //delete by id if DB is not oracle
             while (true) {
                 Set<String> xidSet = TCC_FENCE_DAO.queryEndStatusXidsByDate(connection, datetime, LIMIT_DELETE);
                 if (xidSet.isEmpty()) {
@@ -312,6 +319,16 @@ public static int deleteFenceByDate(Date datetime) {
 
     }
 
+    private static boolean isOracle(Connection connection) {
+        try {
+            String driverName = connection.getMetaData().getDriverName();
+            return driverName.toUpperCase().contains("ORACLE");
+        } catch (SQLException e) {
+            LOGGER.error("get db type fail",e);
+        }
+        return false;
+    }
+
     private static void initLogCleanExecutor() {
         logCleanExecutor = new ThreadPoolExecutor(MAX_THREAD_CLEAN, MAX_THREAD_CLEAN, Integer.MAX_VALUE,
                 TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(),

tcc/src/main/java/io/seata/rm/tcc/store/TCCFenceStore.java

@@ -85,10 +85,10 @@ public interface TCCFenceStore {
      * Delete tcc fence by datetime.
      * @param conn the connection
      * @param datetime datetime
-     * @param limit limit
      * @return the deleted row count
      */
-    int deleteTCCFenceDOByDate(Connection conn, Date datetime, int limit);
+    int deleteTCCFenceDOByDate(Connection conn, Date datetime);
+
 
     /**
      * Set LogTable Name

tcc/src/main/java/io/seata/rm/tcc/store/db/TCCFenceStoreDataBaseDAO.java

@@ -192,13 +192,12 @@ public int deleteTCCFenceDO(Connection conn, List<String> xids) {
     }
 
     @Override
-    public int deleteTCCFenceDOByDate(Connection conn, Date datetime, int limit) {
+    public int deleteTCCFenceDOByDate(Connection conn, Date datetime) {
         PreparedStatement ps = null;
         try {
             String sql = TCCFenceStoreSqls.getDeleteSQLByDateAndStatus(logTableName);
             ps = conn.prepareStatement(sql);
             ps.setTimestamp(1, new Timestamp(datetime.getTime()));
-            ps.setInt(2, limit);
             return ps.executeUpdate();
         } catch (SQLException e) {
             throw new StoreException(e);

tcc/src/main/java/io/seata/rm/tcc/store/db/sql/TCCFenceStoreSqls.java

@@ -84,8 +84,7 @@ private TCCFenceStoreSqls() {
      */
     protected static final String DELETE_BY_DATE_AND_STATUS = "delete from " + LOCAL_TCC_LOG_PLACEHOLD
             + " where gmt_modified < ? "
-            + " and status in (" + TCCFenceConstant.STATUS_COMMITTED + " , " + TCCFenceConstant.STATUS_ROLLBACKED + " , " + TCCFenceConstant.STATUS_SUSPENDED + ")"
-            + " limit ?";
+            + " and status in (" + TCCFenceConstant.STATUS_COMMITTED + " , " + TCCFenceConstant.STATUS_ROLLBACKED + " , " + TCCFenceConstant.STATUS_SUSPENDED + ")";
 
     public static String getInsertLocalTCCLogSQL(String localTccTable) {
         return INSERT_LOCAL_TCC_LOG.replace(LOCAL_TCC_LOG_PLACEHOLD, localTccTable);