| | |
|---|
| | | 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主库的内容 |
|---|
