CXF协议WebService+Spring客户端和服务端程序，实现了多数据源动态切换

package com.dsg.server.dynamic.dao.impl; import java.util.List; import java.util.Map; import org.springframework.stereotype.Repository; import com.dsg.server.dynamic.bean.DynamicDataSourceContext; import com.dsg.server.dynamic.dao.BaseJDBCDAO; import com.dsg.server.dynamic.dao.DynamicOperationDao; @Repository("dynamicOperationDao") public class DynamicOperationDaoImpl extends BaseJDBCDAO implements DynamicOperationDao { @Override public List<Map<String, Object>> getTableSpaceDataInfo(String dbId, int offset, int pageSize) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); int end = offset + pageSize; String sql = "Select * FROM( select * from ( " + "select m.*,rownum rn from ( select ID,TABLESPACE_NAME,SUM_SPACE,SUM_BLOCKS," + "USED_SPACE,USED_RATE,FREE_SPACE,DATE_TIME from ( " + "SELECT rownum ID,D.TABLESPACE_NAME,SPACE SUM_SPACE,BLOCKS SUM_BLOCKS, " + "SPACE - NVL(FREE_SPACE, 0) USED_SPACE, " + "ROUND((1 - NVL(FREE_SPACE, 0) / SPACE) * 100, 2) USED_RATE, FREE_SPACE ," + "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') DATE_TIME FROM (SELECT TABLESPACE_NAME, " + "ROUND(SUM(BYTES) / (1024 * 1024), 2) SPACE, SUM(BLOCKS) BLOCKS FROM DBA_DATA_FILES " + "GROUP BY TABLESPACE_NAME) D,(SELECT TABLESPACE_NAME, ROUND(SUM(BYTES) / (1024 * 1024), 2) " + "FREE_SPACE FROM DBA_FREE_SPACE GROUP BY TABLESPACE_NAME) F WHERE D.TABLESPACE_NAME = " + "F.TABLESPACE_NAME(+) UNION ALL SELECT rownum ID,D.TABLESPACE_NAME,SPACE SUM_SPACE,BLOCKS " + "SUM_BLOCKS,USED_SPACE , ROUND(NVL(USED_SPACE, 0) / SPACE * 100, 2) USED_RATE, " + "NVL(FREE_SPACE, 0) FREE_SPACE ," + "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') DATE_TIME FROM (SELECT TABLESPACE_NAME, " + "ROUND(SUM(BYTES) / (1024 * 1024), 2) SPACE, SUM(BLOCKS) BLOCKS FROM DBA_TEMP_FILES " + "GROUP BY TABLESPACE_NAME) D, (SELECT TABLESPACE_NAME, ROUND(SUM(BYTES_USED) / " + "(1024 * 1024), 2) USED_SPACE, ROUND(SUM(BYTES_FREE) / (1024 * 1024), 2) " + "FREE_SPACE FROM V$TEMP_SPACE_HEADER GROUP BY TABLESPACE_NAME) F " + "WHERE D.TABLESPACE_NAME = F.TABLESPACE_NAME(+) ) where 1=1 order by SUM_SPACE desc ) m ) " + "WHERE rn <= " + end + " ) WHERE rn > " + offset + " "; return this.getList(sql); } @Override public int countTableSpaceDataInfo(String dbId) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sql = "Select * FROM( select * from ( " + "select m.*,rownum rn from ( select ID,TABLESPACE_NAME,SUM_SPACE,SUM_BLOCKS," + "USED_SPACE,USED_RATE,FREE_SPACE,DATE_TIME from ( " + "SELECT rownum ID,D.TABLESPACE_NAME,SPACE SUM_SPACE,BLOCKS SUM_BLOCKS, " + "SPACE - NVL(FREE_SPACE, 0) USED_SPACE, " + "ROUND((1 - NVL(FREE_SPACE, 0) / SPACE) * 100, 2) USED_RATE, FREE_SPACE ," + "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') DATE_TIME FROM (SELECT TABLESPACE_NAME, " + "ROUND(SUM(BYTES) / (1024 * 1024), 2) SPACE, SUM(BLOCKS) BLOCKS FROM DBA_DATA_FILES " + "GROUP BY TABLESPACE_NAME) D,(SELECT TABLESPACE_NAME, ROUND(SUM(BYTES) / (1024 * 1024), 2) " + "FREE_SPACE FROM DBA_FREE_SPACE GROUP BY TABLESPACE_NAME) F WHERE D.TABLESPACE_NAME = " + "F.TABLESPACE_NAME(+) UNION ALL SELECT rownum ID,D.TABLESPACE_NAME,SPACE SUM_SPACE,BLOCKS " + "SUM_BLOCKS,USED_SPACE , ROUND(NVL(USED_SPACE, 0) / SPACE * 100, 2) USED_RATE, " + "NVL(FREE_SPACE, 0) FREE_SPACE ," + "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') DATE_TIME FROM (SELECT TABLESPACE_NAME, " + "ROUND(SUM(BYTES) / (1024 * 1024), 2) SPACE, SUM(BLOCKS) BLOCKS FROM DBA_TEMP_FILES " + "GROUP BY TABLESPACE_NAME) D, (SELECT TABLESPACE_NAME, ROUND(SUM(BYTES_USED) / " + "(1024 * 1024), 2) USED_SPACE, ROUND(SUM(BYTES_FREE) / (1024 * 1024), 2) " + "FREE_SPACE FROM V$TEMP_SPACE_HEADER GROUP BY TABLESPACE_NAME) F " + "WHERE D.TABLESPACE_NAME = F.TABLESPACE_NAME(+) ) where 1=1 order by SUM_SPACE desc ) m ) " + ") "; return this.getTotalCount(sql); } @Override public List<Map<String, Object>> getStoreIOInfoByFileName(String dbId, int offset, int pageSize) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sqlString = "select file_name,PHYWRTS,PHYRDS from v$filestat v ,dba_data_files df " + "where v.file# = df.file_id ORDER BY file_name DESC"; sqlString = this.getPageSql(sqlString, offset, pageSize); return this.getList(sqlString); } @Override public int countStoreIOInfoByFileName(String dbId) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sqlString = "select file_name,PHYWRTS,PHYRDS from v$filestat v ,dba_data_files df " + "where v.file# = df.file_id ORDER BY file_name DESC"; return this.getTotalCount(sqlString); } @Override public List<Map<String, Object>> getStoreIOInfoByTableSpaceName( String dbId, int offset, int pageSize) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sqlString = "select TABLESPACE_NAME,sum(PHYWRTS),sum(PHYRDS) from v$filestat v ," + " dba_data_files df where v.file# = df.file_id group by rollup(TABLESPACE_NAME)" + " order by df.TABLESPACE_NAME"; sqlString = this.getPageSql(sqlString, offset, pageSize); return this.getList(sqlString); } @Override public int countStoreIOInfoByTableSpaceName(String dbId) { // TODO Auto-generated method stub String sqlString = "select TABLESPACE_NAME,sum(PHYWRTS),sum(PHYRDS) from v$filestat v ," + " dba_data_files df where v.file# = df.file_id group by rollup(TABLESPACE_NAME)" + " order by df.TABLESPACE_NAME"; return this.getTotalCount("select * from ("+sqlString+")aa"); } @Override public List<Map<String, Object>> getOracleCpuInfo(String dbId) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sql = "select stat_name, Round(value/1000000) \"Time(Sec)\" from v$sys_time_model" + " where stat_name = 'DB CPU'"; return this.getList(sql); } @Override public List<Map<String, Object>> getOracleSgaInfo(String dbId, int offset, int pageSize) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sqlString = "SELECT rownum ID,i.instance_name INSTANCE_NAME, s.sga_size SGA_SIZE,p.value SGA_VALUE,TO_CHAR(s.sga_size_factor,'fm99999999990.0099') SGA_SIZE_FACTOR, s.estd_db_time ESTD_DB,s.estd_db_time_factor ESTD_FACTOR,s.estd_physical_reads ESTD_READS"+ " FROM gv$sga_target_advice s,gv$instance i, (select inst_id, min(value) value from "+ " (SELECT i.inst_id, p.value/1024/1024 value FROM gv$parameter p, gv$instance i WHERE p.inst_id = i.inst_id AND p.name IN ('sga_max_size', 'sga_target')"+ " ORDER BY i.instance_name, p.name ) group by inst_id) p WHERE s.inst_id = i.inst_id and p.INST_ID = i.INST_ID ORDER BY i.instance_name, s.sga_size_factor"; sqlString = this.getPageSql(sqlString, offset, pageSize); return this.getList(sqlString); } @Override public int countOracleSgaInfo(String dbId) { // TODO Auto-generated method stub DynamicDataSourceContext.set(dbId); String sqlString = "SELECT rownum ID,i.instance_name INSTANCE_NAME, s.sga_size SGA_SIZE," + "p.value SGA_VALUE,TO_CHAR(s.sga_size_factor,'fm99999999990.0099') SGA_SIZE_FACTOR," + " s.estd_db_time ESTD_DB,s.estd_db_time_factor ESTD_FACTOR,s.estd_physical_reads ESTD_READS"+ " FROM gv$sga_target_advice s,gv$instance i, (select inst_id, min(value) value from "+ " (SELECT i.inst_id, p.value/1024/1024 value FROM gv$parameter p, gv$instance i WHERE p.inst_id = i.inst_id AND p.name IN ('sga_max_size', 'sga_target')"+ " ORDER BY i.instance_name, p.name ) group by inst_id) p WHERE s.inst_id = i.inst_id and p.INST_ID = i.INST_ID ORDER BY i.instance_name, s.sga_size_factor"; return this.getTotalCount(sqlString); } @Override public List<Map<String, Object>> getOr