package com.vci.server.omd.ddlTool;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.vci.corba.omd.ddl.DDLService;
import com.zeroc.Ice.Current;

public class DDLServiceImpl implements DDLService{
	private static final Logger logger = LogManager.getLogger(DDLServiceImpl.class);
	/**
	 * 为业务类型生成Oracle DDL
	 */
	@Override
	public boolean generatorODDLForBt(String apContent, String btContent, Current current) {
		DDLForOracle gOracle = DDLForOracle.getInstance();
		boolean flag = gOracle.generatorODDLForBt(apContent, btContent);
		if(flag){
			logger.info("Oracle DDL FOR BT success");
		}else{
			logger.warn("Oracle DDL FOR BT failure");
		}
		return flag;
	}

	/**
	 * 为业务类型生成SQLServer DDL
	 */
	@Override
	public boolean generatorSDDLForBt(String apContent, String btContent, Current current) {
		DDLForSQLServer gSQLServer = DDLForSQLServer.getInstance();
		boolean flag = gSQLServer.generatorSDDLForBt(apContent, btContent);
		if(flag){
			logger.info("SQLServer DDL FOR BT success");
		}else{
			logger.warn("SQLServer DDL FOR BT failure");
		}
		return flag;
	}

	/**
	 * 为链接类型生成Oracle DDL
	 */
	@Override
	public boolean generatorODDLForLt(String apContent, String ltContent, Current current) {
		DDLForOracle gOracle = DDLForOracle.getInstance();
		boolean flag = gOracle.generatorODDLForLt(apContent, ltContent);
		if(flag){
			logger.info("Oracle DDL FOR LT success");
		}else{
			logger.warn("Oracle DDL FOR LT failure");
		}
		return flag;
	}
	

	/**
	 * 为链接类型生成SqlServer DDL
	 */
	@Override
	public boolean generatorSDDLForLt(String apContent, String ltContent, Current current) {
		DDLForSQLServer gSQLServer = DDLForSQLServer.getInstance();
		boolean flag = gSQLServer.generatorSDDLForLt(apContent, ltContent);
		if(flag){
			logger.info("SQLServer DDL FOR BT success");
		}else{
			logger.warn("SQLServer DDL FOR BT failure");
		}
		return flag;
	}

	/**
	 * 创建, 修改, 刪除业务类型Table Oracle
	 */
	@Override
	public boolean executeUpdateOracle(String sql, Current current){
		DDLForOracle gOracle = DDLForOracle.getInstance();
		boolean flag = gOracle.executeUpdate(sql);
		return flag;
	}

	/**
	 * 创建, 修改, 刪除业务类型Table SQLServer
	 */
	@Override
	public boolean executeUpdateSQLServer(String sql, Current current) {
		//TODO
		return false;
	}
	
	/**
	 * 批量执行SQL
	 */
	@Override
	public boolean batchExecuteUpdateOracle(String[] sqlArray, Current current) {
		DDLForOracle gOracle = DDLForOracle.getInstance();
		boolean flag = true;
		for(String sql : sqlArray){
			if(!gOracle.executeUpdate(sql)){
				flag = false;
			}
		}
		return flag;
	}

	/**
	 * 批量执行SQL
	 */
	@Override
	public boolean batchExecuteUpdateSQLServer(String[] sqlArray, Current current) {
		return false;
	}

	/**
	 * 记录修改Table DDL(alter table t add(column type)
	 * Oracle
	 */
	@Override
	public boolean alterTableDDLOracle(String sql, Current current) {
		DDLForOracle gOracle = DDLForOracle.getInstance();
		gOracle.alterTableDDL(sql);
		return true;
	}

	/**
	 * 记录修改Table DDL(alter table t add(column type)
	 * SQLServer
	 */
	@Override
	public boolean alterTableDDLSQLServer(String sql, Current current) {
		//TODO
		return false;
	}

	/**
	 * 检查业务类型, 链接类型在数据库中是否已有数据对象Oracle
	 */
	@Override
	public boolean hasInstanceOralce(String name, Current current) {
		DDLForOracle gOracle = DDLForOracle.getInstance();
		return gOracle.hasInstance(name);
	}

	/**
	 * 检查业务类型, 链接类型在数据库中是否已有数据对象SQLServer
	 */
	@Override
	public boolean hasInstanceSQLServer(String name, Current current) {
		// TODO Auto-generated method stub
		return false;
	}
}