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;
|
}
|
}
|