AE86 1 anno fa
parent
commit
9737d119d1

+ 1 - 9
dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/connector/database/sqlbuilder/SqlBuilderQueryCount.java

@@ -6,9 +6,6 @@ package org.dbsyncer.sdk.connector.database.sqlbuilder;
 import org.dbsyncer.common.util.StringUtil;
 import org.dbsyncer.sdk.config.SqlBuilderConfig;
 import org.dbsyncer.sdk.connector.database.Database;
-import org.dbsyncer.sdk.util.PrimaryKeyUtil;
-
-import java.util.List;
 
 /**
  * @author AE86
@@ -22,12 +19,11 @@ public class SqlBuilderQueryCount extends SqlBuilderQuery {
         Database database = config.getDatabase();
         String quotation = database.buildSqlWithQuotation();
         String tableName = config.getTableName();
-        List<String> primaryKeys = database.buildPrimaryKeys(config.getPrimaryKeys());
         String schema = config.getSchema();
         String queryFilter = config.getQueryFilter();
 
         StringBuilder sql = new StringBuilder();
-        sql.append("SELECT COUNT(1) FROM (SELECT 1 AS ").append(quotation).append("_ROW").append(quotation).append(" FROM ");
+        sql.append("SELECT COUNT(1) FROM ");
         sql.append(schema);
         sql.append(quotation);
         sql.append(database.buildTableName(tableName));
@@ -35,10 +31,6 @@ public class SqlBuilderQueryCount extends SqlBuilderQuery {
         if (StringUtil.isNotBlank(queryFilter)) {
             sql.append(queryFilter);
         }
-        sql.append(" GROUP BY ");
-        // id,uid
-        PrimaryKeyUtil.buildSql(sql, primaryKeys, quotation, ",", "", true);
-        sql.append(") DBSYNCER_T");
         return sql.toString();
     }