fix(dlm): create target table failed (#1614)

Author: guowl3

server/odc-service/src/main/java/com/oceanbase/odc/service/schedule/job/DataArchiveJob.java

@@ -18,13 +18,10 @@
 import java.util.List;
 
 import org.quartz.JobExecutionContext;
-import org.springframework.jdbc.core.JdbcOperations;
-import org.springframework.jdbc.support.rowset.SqlRowSet;
 
 import com.oceanbase.odc.common.json.JsonUtils;
 import com.oceanbase.odc.core.session.ConnectionSession;
 import com.oceanbase.odc.core.session.ConnectionSessionConstants;
-import com.oceanbase.odc.core.shared.constant.DialectType;
 import com.oceanbase.odc.core.shared.constant.TaskStatus;
 import com.oceanbase.odc.metadb.schedule.ScheduleTaskEntity;
 import com.oceanbase.odc.service.common.util.SpringContextUtil;
@@ -35,9 +32,6 @@
 import com.oceanbase.odc.service.task.config.DefaultTaskFrameworkProperties;
 import com.oceanbase.odc.service.task.config.TaskFrameworkProperties;
 import com.oceanbase.tools.dbbrowser.schema.DBSchemaAccessor;
-import com.oceanbase.tools.dbbrowser.util.MySQLSqlBuilder;
-import com.oceanbase.tools.dbbrowser.util.OracleSqlBuilder;
-import com.oceanbase.tools.dbbrowser.util.SqlBuilder;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -98,14 +92,10 @@ private void createTargetTable(DlmTask dlmTask) {
         DefaultConnectSessionFactory sourceConnectionSessionFactory =
                 new DefaultConnectSessionFactory(dlmTask.getSourceDs());
         ConnectionSession srcSession = sourceConnectionSessionFactory.generateSession();
-        JdbcOperations jdbcOperations = srcSession.getSyncJdbcExecutor(ConnectionSessionConstants.CONSOLE_DS_KEY);
         String tableDDL;
         try {
-            SqlRowSet sqlRowSet =
-                    jdbcOperations.queryForRowSet(getCreateTableDDL(dlmTask.getSourceDs().getDefaultSchema(),
-                            dlmTask.getTableName(), dlmTask.getSourceDs()
-                                    .getDialectType()));
-            tableDDL = sqlRowSet.getString(2);
+            DBSchemaAccessor sourceDsAccessor = DBSchemaAccessors.create(srcSession);
+            tableDDL = sourceDsAccessor.getTableDDL(dlmTask.getSourceDs().getDefaultSchema(), dlmTask.getTableName());
         } finally {
             srcSession.expire();
         }
@@ -127,13 +117,4 @@ private void createTargetTable(DlmTask dlmTask) {
         }
     }
 
-    private String getCreateTableDDL(String schemaName, String tableName, DialectType dbType) {
-        SqlBuilder sb = dbType.isOracle() ? new OracleSqlBuilder() : new MySQLSqlBuilder();
-        sb.append("SHOW CREATE TABLE ");
-        sb.identifier(schemaName);
-        sb.append(".");
-        sb.identifier(tableName);
-        return sb.toString();
-    }
-
 }