TRS.WCM.Developer/test/com/trs/exchange/metadata/MetaDataExchangeImplTest.java

package com.trs.exchange.metadata;

import com.trs.TRSWCMBaseTest;
import com.trs.exchange.MyDBManager;
import com.trs.infra.persistent.WCMFilter;
import com.trs.infra.util.CMyException;
import com.trs.infra.util.database.MysqlDB;

public class MetaDataExchangeImplTest extends TRSWCMBaseTest {
	private static org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(MetaDataExchangeImplTest.class);

	public MetaDataExchangeImplTest(String name) {
		super(name);
	}

	/**
	 * 测试简单元数据迁移
	 */
	public void testCreateMetaViewDatas() {
		MyDBManager oMyDBManager = null;
		try {
			// 设定源数据库的信息
			// 支持的源数据库类型：OracleDB11G OracleDB SQLServerDB MysqlDB
			// SybaseASEWithJtds
			// DB2UDBV9 KingBaseDB
			oMyDBManager = new MyDBManager("MySQL",
					"jdbc:mysql://127.0.0.1:3306/test?characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull",
					"root", "trsadmin", MysqlDB.class);

			// 设置读取数据的SQL，使用别名和海云中的视图字段保持一致
			// 必须包含DocOutupId，为源数据ID，CrTime数据的创建时间，CrUser数据的创建者
			WCMFilter oFilterForQuerySrcData = new WCMFilter("MyData", "", "",
					"MyId,MyTitle CTitle, MyContent CContent, MyId DocOutupId, MyTime CrTime, MyUser CrUser");

			MetaDataExchangeImpl oMetaDataExchange = new MetaDataExchangeImpl(oMyDBManager);

			// 目标栏目
			int nDstChannelId = 65;

			// 开始迁移
			oMetaDataExchange.createMetaViewDatas(m_oLoginUser, nDstChannelId, oFilterForQuerySrcData, "MyId", true);
		} catch (Exception ex) {
			logger.error("测试[testCreateMetaViewDatas]出现异常！", ex);
			fail("测试[testCreateMetaViewDatas]出现异常！\n" + CMyException.getStackTraceText(ex));
		} finally {
			if (oMyDBManager != null)
				oMyDBManager.close();
		}
	}

	/**
	 * 测试包含视频的元数据迁移
	 */
	public void testCreateMetaViewDatasContainMedia() {
		MyDBManager oMyDBManager = null;
		try {
			// 设定源数据库的信息
			// 支持的源数据库类型：OracleDB11G OracleDB SQLServerDB MysqlDB
			// SybaseASEWithJtds
			// DB2UDBV9 KingBaseDB
			oMyDBManager = new MyDBManager("MySQL",
					"jdbc:mysql://127.0.0.1:3306/test?characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull",
					"root", "trsadmin", MysqlDB.class);

			WCMFilter oFilterForQuerySrcData = new WCMFilter("MyData", "", "",
					"MyTitle CTitle, MyContent CContent, MyId DocOutupId, MyMediaFile MyMediaFile");

			// 设定源系统存放文件的信息
			MetaDataExchangeImpl oMetaDataExchange = new MetaDataExchangeImpl(oMyDBManager);

			// 设置MAS相关信息
			int nDirId = 1; // Mas目录地址
			oMetaDataExchange.setMASInfo("http://127.0.0.1:8181/mas/", nDirId);

			// 目标栏目
			int nDstChannelId = 56;

			// 开始迁移
			oMetaDataExchange.createMetaViewDatas(m_oLoginUser, nDstChannelId, oFilterForQuerySrcData, "MyId", true);
		} catch (Exception ex) {
			logger.error("测试[testCreateMetaViewDatas]出现异常！", ex);
			fail("测试[testCreateMetaViewDatas]出现异常！\n" + CMyException.getStackTraceText(ex));
		} finally {
			if (oMyDBManager != null)
				oMyDBManager.close();
		}
	}

}