| | |
|---|
| | | 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))) { |
|---|
