更新时间:2022-02-05 21:04:08
<dependency> <groupId>com.bbossgroups</groupId> <artifactId>bboss-persistent</artifactId> <version>5.0.7.1</version> </dependency>
compile 'com.bbossgroups:bboss-persistent:5.0.7.1'
try{ SQLUtil.startPool("test",//数据源名称 "com.mysql.jdbc.Driver",//oracle驱动 "jdbc:mysql://localhost:3306/bboss",//mysql链接串 "root","123456",//数据库账号和口令 "select 1 " //数据库连接校验sql );
List<HashMap> datas = SQLExecutor.queryListWithDBName(HashMap.class,"test", "select * from t_hive"); for(int i = 0; datas != null && i < datas.size(); i ++) { System.out.println(datas.get(i)); } } catch(SQLException e) { e.printStackTrace(); }
<properties> <property name="tdSmUserJobOrgSelect"> <![CDATA[ select * from td_sm_userjoborg where user_id=#[userId] ]]> </property> </properties>
com.frameworkset.common.poolman.ConfigSQLExecutor dao= new com.frameworkset.common.poolman.ConfigSQLExecutor("com/test/sql/test.xml"); //指定dbname为test String dbname="test"; List<HashMap> datas = dao.queryListWithDBName(HashMap.class,dbname, "tdSmUserJobOrgSelect"); for(int i = 0; datas != null && i < datas.size(); i ++) { System.out.println(datas.get(i)); } } catch(SQLException e) { e.printStackTrace(); }
List<HashMap> datas = dao.queryList(HashMap.class, "tdSmUserJobOrgSelect"); for(int i = 0; datas != null && i < datas.size(); i ++) { System.out.println(datas.get(i)); } } catch(SQLException e) { e.printStackTrace(); }
import com.frameworkset.common.poolman.util.JDBCPoolMetaData; import com.frameworkset.common.poolman.DBUtil; DBUtil dbUtil = new DBUtil(); Enumeration enum_ = dbUtil.getAllPoolnames(); while(enum_.hasMoreElements()){ String poolname = (String)enum_.nextElement(); JDBCPoolMetaData metadata = DBUtil.getPool(poolname).getJDBCPoolMetadata(); }