| | |
|---|
| | | String maxID = paramFse.getString("max_id"); |
|---|
| | | String minID = paramFse.getString("min_id"); |
|---|
| | | String splitTableType = "1".equals(configFse.getString("split_table_type")) ? "1" : "0"; |
|---|
| | | //开启队列查询时，先清空队列防止上次未处理完的数据占用内存 |
|---|
| | | dataArchivingQueue.clear(sourceTable); |
|---|
| | | dataArchivingQueue.query(sourceDbe, sourceTable, filterSb.toString(), null, uniqueField, minID); |
|---|
| | | DataTableEntity allDte; |
|---|
| | | Map<String, List<DataTableEntity>> groupDteMap; |
|---|
| | |
|---|
| | | targetDao.closeConnection(); |
|---|
| | | sourceDao.closeConnection(); |
|---|
| | | // 关闭线程 |
|---|
| | | dataArchivingQueue.shutdownQueryThread(sourceTable); |
|---|
| | | dataArchivingQueue.clear(sourceTable); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 删除mes主库的内容 |
|---|
| | |
|---|
| | | for (String indexName : indexInfoObj.keySet()) { |
|---|
| | | singleFieldInfoObj = indexInfoObj.getJSONObject(indexName); |
|---|
| | | if (CmnConst.PRIMARY.equalsIgnoreCase(indexName) || CmnConst.PRIMARY.equalsIgnoreCase(singleFieldInfoObj.getString(CmnConst.TYPE))) { |
|---|
| | | sql.append("\n PRIMARY KEY (`").append(singleFieldInfoObj.getString(CmnConst.COLUMN_NAME)).append("`) USING BTREE,"); |
|---|
| | | sql.append("\n PRIMARY KEY (").append(singleFieldInfoObj.getString(CmnConst.COLUMN_NAME)).append(") USING BTREE,"); |
|---|
| | | } else if (CmnConst.UNIQUE.equalsIgnoreCase(singleFieldInfoObj.getString(CmnConst.TYPE))) { |
|---|
| | | sql.append("\n UNIQUE INDEX `").append(indexName).append("`(").append(singleFieldInfoObj.getString(CmnConst.COLUMN_NAME)).append(") USING BTREE,"); |
|---|
| | | } else if (CmnConst.NORMAL.equalsIgnoreCase(singleFieldInfoObj.getString(CmnConst.TYPE))) { |
|---|
