private ICompDbcpService compDbcpService;
protect ConnectionParam provider;
public ICompDbcpService getComDbcpService(){
if(compDbcpService == null){
compDbcpService = (ICompDbcpService) SpringBeanUtil.getBean("compDbcpService");
return compDbcpService;
}
}
/**
* 获取数据库
**/
public ConnectionParam getConnectionParam() throws Exception{
if(provider == null){
String dataSource = "eltArchives"; //数据源配置的名称
CompDbcp compDbcp = (CompDbcp) getCompDbcpService().getCompDbcpByName(dataSource);
if(compDbcp == null){
throw new KmssRuntimeException(new KmssMessage("配置数据源出错!");)
}
provider = ConnectionProviderUtil.getInstance(compDbcp);
}
return provider;
}
/**
* 获取链接
**/
private Connection getConn(){
Connection conn = null;
try{
//两个conn的区别,一个是插在我们数据库,一个是插在对方数据库
conn = sysOrgElementService.getBaseDao().getHibernateSession.connection();
//conn = ConnectionProviderUtil.getConnection(getConnectionParam());
} catch(Exception e){
e.printStatckTrace();
}
return conn;
}
/**
* 执行sql
*/
private void execute(String sql){
Connection conn = getConn();
PreparedStatement pstmt;
try{
pstmt = conn.prepareStatement(sql);
boolean result = pstmt.execute();
pstmt.close();
conn.close();
}catch(SQLException e){
e.printStackTarce();
}
获取自定义表达某个字段
Map extendData;
try{
mainModel.getExtendDataModelInfo().getModelData();
Map docCreator = (Map) extendData.get("fd_371c5e1cc264a4"); //提交人
String docCreatorId = ""; //创建人ID
String docCreatorName = ""; //创建人姓名
String post = ""; //部门
if(docCreator != null){
docCreatorId = (String) docCreatorId.get("id");
docCreatorName = (String) docCreatorName.get("name");
SysOrgElement person = (SysOrgElement) sysOrgElementService.findByPrimaryKey(docCreatorId);
if(person != null && person.getFdParent() != null){
post = person.getFdParent().getFdName();
}
}
}catch(Exception e){
logger.error("加载表单数据失败");
e.printStackTrace();
}
网友评论