Network Security Internet Technology Development Database Servers Mobile Phone Android Software Apple Software Computer Software News IT Information

In addition to Weibo, there is also WeChat

Please pay attention

WeChat public account

Shulou

Jdbc link database (including connection pooling)

2025-01-18 Update From: SLTechnology News&Howtos shulou NAV: SLTechnology News&Howtos > Database >

Share

Shulou(Shulou.com)06/01 Report--

/ *

* Copyright 2000-2020 YGSoft.Inc All Rights Reserved.

, /

Package com.ygsoft.gris.mapp.materialmanage.impl.util

Import java.math.BigDecimal

Import java.sql.CallableStatement

Import java.sql.Connection

Import java.sql.ResultSet

Import java.sql.SQLException

Import java.sql.Statement

Import java.text.DecimalFormat

Import java.text.NumberFormat

Import java.util.ArrayList

Import java.util.List

Import java.util.Map

Import com.ygsoft.ecp.service.tool.StringUtil

Import com.ygsoft.gris.mapp.materialmanage.service.model.EngineeringMaterialsOutVO

Import com.ygsoft.gris.mapp.materialmanage.service.model.QueryConditionsVO

Import com.ygsoft.gris.mapp.materialmanage.service.model.SupplierInvoiceInfoVO

Import com.ygsoft.gris.mapp.materialmanage.service.model.SupplierZanguSupplies

Import com.ygsoft.gris.mapp.materialmanage.service.model.Tm0001CatalogsVO

/ * *

* sqlService database connection.

*

* @ author mapengfei

* @ version 1.0.0 October 13, 2016

* @ see

* @ since JDK 1.5.0

, /

Public class SqlServerDbConnectionUtil {

Private static boolean ISTESTDATA = true

/ * *

* Internal lazy loading class.

*

* @ author mapengfei

* @ version 1.0.0 May 31, 2016

* @ see

* @ since JDK 1.5.0

, /

Private static class LazyHolder {

Private static final SqlServerDbConnectionUtil INSTANCE = new SqlServerDbConnectionUtil ()

}

/ * *

* New implementation of singleton

*

* @ return

, /

Public static final SqlServerDbConnectionUtil getInstance () {

Return LazyHolder.INSTANCE

}

/ * *

* @ param args

, /

Public static void main (final String [] args) {

/ / TODO Auto-generated method stub

/ / SqlServerDbConnectionUtil util = new SqlServerDbConnectionUtil ()

/ / util.dbConnection ()

/ / List list =

/ / SqlServerDbConnectionUtil.findAllMaterialsOutByCondition (null)

List list = findExcelExportByCondition (null, "ZGWZ")

System.out.println (list)

}

/ * *

* get database links

*

* @ return

, /

Private static Connection getCurrentConnecton () {

/ / initialize connection pooling

ConnectionPool pool = getPool ()

/ / get the current link

Connection conn = pool.getCurrentConnecton ()

If (conn! = null) {

Return conn

}

Return null

}

/ * *

* Singleton mode initializes a connection pool

*

* @ return

, /

Public static ConnectionPool getPool () {

Return ConnectionPoolManager.getInstance () .getPool (sqllitePool)

}

/ * *

* query according to conditions

*

* @ return

, /

Public static List findAllMaterialsOutByCondition (

Final QueryConditionsVO queryCondition) {

If (ISTESTDATA) {

Return TestData.findAllMaterialsOutByCondition (queryCondition)

}

List list = new ArrayList ()

Connection conn = null

Try {

Conn = getCurrentConnecton ()

Statement stat = conn.createStatement ()

String sql = setQueryConditionsSql (queryCondition, "CLCK", 1000)

ResultSet rs = stat.executeQuery (sql)

EngineeringMaterialsOutVO out = null

Int I = 1

While (rs.next ()) {

Out = new EngineeringMaterialsOutVO ()

Out.setNo ("" + I)

Out.setTotal (rs.getBigDecimal (7))

Out.setProDefinition (! StringUtil.isNotEmptyString (rs.getString (3))? "": rs.getString (3). ToString (); / / Engineering definition

Out.setNotTaxAmount (BigDecimal.valueOf (rs.getDouble (4)

Out.setProName (! StringUtil.isNotEmptyString (rs.getString (2))? "": rs.getString (2) .toString (); / / name

Out.setProNumber (! StringUtil.isNotEmptyString (rs.getString (1))? "": rs.getString (1) .toString (); / / Encoding

Out.setTax (rs.getDouble (6))

Out.setTaxRate (rs.getDouble (5))

List.add (out)

ITunes +

}

Rs.close ()

Stat.close ()

} catch (SQLException e) {

/ / TODO Auto-generated catch block

E.printStackTrace ()

} finally {

CloseConnection (conn)

}

Return list

}

/ * *

* summary of provisional estimated materials

*

* @ return

, /

Public static List findAllSupplierZanguSuppliesByCondition (

Final QueryConditionsVO queryCondition) {

If (ISTESTDATA) {

Return TestData.findAllSupplierZanguSuppliesByCondition (queryCondition)

}

List list = new ArrayList ()

Connection conn = null

Try {

Conn = getCurrentConnecton ()

Statement stat = conn.createStatement ()

String sql = setQueryConditionsSql (queryCondition, "ZGWZ", 1000)

ResultSet rs = stat.executeQuery (sql)

SupplierZanguSupplies out = null

Int I = 0

While (rs.next ()) {

Out = new SupplierZanguSupplies ()

Out.setNo ("" + I)

Out.setInStoragePrice (rs.getBigDecimal (3)); / / purchase price

Out.setInvoicePrice (rs.getBigDecimal (7)); / / invoice price

/ out.setNo (rs.getString (1))

Out.setNotInvoicePrice (rs.getBigDecimal (8)); / / not × × × price

Out.setPurAmount (rs.getBigDecimal (2)); / / purchase amount

Out.setSupplier (rs.getString (1))

Out.setTax (rs.getBigDecimal (5))

Out.setTaxRate (rs.getBigDecimal (4))

Out.setTotalPrice (rs.getBigDecimal (6)); / / Total import tax

List.add (out)

ITunes +

}

Rs.close ()

Stat.close ()

} catch (SQLException e) {

/ / TODO Auto-generated catch block

E.printStackTrace ()

} finally {

CloseConnection (conn)

}

Return list

}

/ * *

* Export data acquisition

*

* @ param supplier

* @ param startTime

* @ param endTime

* @ return

, /

Public static List findExcelExportByCondition (final QueryConditionsVO queryCondition

Final String type) {

If (ISTESTDATA) {

Return TestData.findExcelExportByCondition (queryCondition, type)

}

List list = new ArrayList ()

List tm001s = SqlServerDbConnectionUtil.findProductTypeAll ()

Connection conn = null

Try {

Conn = getCurrentConnecton ()

Statement stat = conn.createStatement ()

String sql = setQueryConditionsSql (queryCondition, type, 100000)

ResultSet rs = stat.executeQuery (sql)

ExcelModel out = null

Int col = rs.getMetaData () .getColumnCount ()

Int row = 1

While (rs.next ()) {

Out = new ExcelModel ()

List suns = new ArrayList ()

For (int I = 1; I

< col; i++) { // X轴 out = new ExcelModel(); Object obj = rs.getObject(i) != null ? rs.getObject(i) : ""; if ("FPXX".equals(type)) { // 发票 switch (i) { case 8: case 10: case 12: case 13: case 15: case 17: case 18: case 19: obj = formatMoney(obj.toString(), 2, true); break; case 11: obj = formatMoney(obj.toString(), 0, false) + "%"; break; case 9: case 14: case 16: obj = 0; if (StringUtil.isNotEmptyString(obj.toString())) { long num = Long.parseLong(obj.toString()); obj = num; } break; default: break; } out.setData(obj); } else if ("ZGWZ".equals(type)) { // 暂估物资 if (i == 1) { ExcelModel out_no = new ExcelModel(); out_no.setData(row); suns.add(out_no); } switch (i) { case 2: case 3: case 5: case 6: case 7: case 8: obj = formatMoney(obj.toString(), 2, true); break; case 4: obj = formatMoney(obj.toString(), 0, false) + "%"; break; default: break; } out.setData(obj); } else { switch (i) { case 5: // 税率 obj = formatMoney(obj.toString(), 0, false) + "%"; break; case 3: String newProtype = ""; Object proType = rs.getString("proType"); List protypes = new ArrayList(); for (Tm0001CatalogsVO c : tm001s) { if (proType.equals(c.getID())) { // 找到节点 newProtype += c.getDisplayName() + "-"; searchProType(tm001s, newProtype, c, protypes); } } obj = protypes.get(0); break; case 4: case 6: case 7: obj = (Object) formatMoney(obj.toString(), 2, true); break; default: out.setData(obj); break; } out.setData(obj); } suns.add(out); } out.setDataList(suns); list.add(out); row++; } rs.close(); stat.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { closeConnection(conn); } return list; } /** * 查询所有的项目分类 * * @return */ public static List findProductTypeAll() { if (ISTESTDATA) { return TestData.findProductTypeAll(); } // 获得测试数据 List list = new ArrayList(); Connection conn = null; try { conn = getCurrentConnecton(); Statement stat = conn.createStatement(); StringBuffer sql = new StringBuffer(" SELECT * FROM TM0001_Catalogs WHERE FieldID=109 "); ResultSet rs = stat.executeQuery(sql.toString()); Tm0001CatalogsVO out = null; while (rs.next()) { out = new Tm0001CatalogsVO(); out.setID(rs.getString(1)); out.setName(rs.getString(2)); out.setDisplayName(rs.getString(3)); out.setParentID(rs.getString(4)); out.setFieldID(rs.getString(5)); out.setObjectID(rs.getString(6)); out.setLevel(rs.getString(7)); out.setComment(rs.getString(8)); list.add(out); } rs.close(); stat.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { closeConnection(conn); } return list; } /** * 查询登录信息的方法 * * @return */ public Map getLoginNameAndStatus() { Connection conn = null; try { conn = getCurrentConnecton(); Statement stat = conn.createStatement(); StringBuffer sql = new StringBuffer(" SELECT * FROM TM0001_Catalogs WHERE FieldID=109 "); ResultSet rs = stat.executeQuery(sql.toString()); while (rs.next()) { } rs.close(); stat.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { closeConnection(conn); } return null; } /** * * @param newNoInvoiceTax * @return */ public static List findAllSupplierInvoiceInfoVOByCondition( final QueryConditionsVO queryCondition) { if (ISTESTDATA) { return TestData.findAllSupplierInvoiceInfoVOByCondition(queryCondition); } List list = new ArrayList(); Connection conn = null; try { conn = getCurrentConnecton(); Statement stat = conn.createStatement(); String sql = setQueryConditionsSql(queryCondition, "FPXX", 1000); ResultSet rs = stat.executeQuery(sql); SupplierInvoiceInfoVO out = null; int i = 1; while (rs.next()) { out = new SupplierInvoiceInfoVO(); out.setNo("" + i); out.setEngineeringCode(rs.getString(5)); // 工程编码 out.setEngineeringName(rs.getString(6)); // 工程名称 out.setInStorageAmount(rs.getBigDecimal(13)); // 入库金额 out.setInStorageNum(rs.getLong(9)); // 入库数量 out.setInStoreAmount(rs.getBigDecimal(10)); // 入库价款 out.setInvoiceAmount(rs.getBigDecimal(15)); // 发票金额 out.setInvoiceNum(rs.getLong(14)); // 发票数量 out.setMaterialCode(rs.getString(2)); // 物资编码 out.setMaterialName(rs.getString(3)); out.setNoInvoiceAmount(rs.getBigDecimal(17)); // 未开票金额 out.setNoInvoiceNum(rs.getLong(16)); // 未开票数量 out.setNoInvoiceTax(rs.getBigDecimal(18)); out.setPurAmount(rs.getBigDecimal(8)); // 采购金额 out.setPurQuantity(rs.getLong(7)); // 采购数量 out.setSpecificationsModel(rs.getString(4)); // 规格型号 out.setSupplier(rs.getString(1)); // 供应商 out.setTax(rs.getBigDecimal(12)); // 税款 out.setTaxRate(rs.getBigDecimal(11)); // 税率 out.setTotalPrice(rs.getBigDecimal(19)); // 价税合计 list.add(out); i++; } rs.close(); stat.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { closeConnection(conn); } return list; } /** * 测试连接 */ @SuppressWarnings("unused") private void dbConnection() { Connection conn = null; try { // Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance(); // String url = // "jdbc:sqlserver://192.168.0.2:1433;DatabaseName=msdb"; // conn = DriverManager.getConnection(url, "sa", "lxm226855"); conn = getCurrentConnecton(); Statement stat = conn.createStatement(); // String sql = "call // cq_gcclckhzb('1321','17','2013-10-21','2016-10-21')"; CallableStatement proc = conn.prepareCall("{call cq_gcclckhzb(?,?,?,?)}"); proc.setString(1, "1321"); proc.setString(2, "17"); proc.setString(3, "2013-10-21"); proc.setString(4, "2016-10-21"); // proc.registerOutParameter(5, Types.VARCHAR); proc.execute(); ResultSet rs = stat.executeQuery("select * from temp_cq_gcclckhzb"); int col = rs.getMetaData().getColumnCount(); while (rs.next()) { for (int i = 1; i -1 ? taxRates[i].substring(0, taxRates[i].length() - 1) : taxRates[i]); if (i != taxRates.length - 1) { sql.append(taxRate + ","); } else { sql.append(taxRate); } } sql.append(" )"); } if (StringUtil.isNotEmptyString(conditions.getProType())) { // 分类 String[] proTypes = conditions.getProType().split(","); sql.append(" and proType in ( "); for (int i = 0; i < proTypes.length; i++) { if (i != proTypes.length - 1) { sql.append("'" + proTypes[i] + "',"); } else { sql.append("'" + proTypes[i] + "'"); } } sql.append(" )"); } if (StringUtil.isNotEmptyString(conditions.getStartTime())) { // 起始日期 sql.append(" and BusinessDate >

='"+ conditions.getStartTime () +"'")

}

If (StringUtil.isNotEmptyString (conditions.getEndTime () {/ / end date

Sql.append ("the maximum number set by and BusinessDate, where forced shutdown is taken")

}

Conn.close ()

}

}

/ * *

* determine whether the connection is available

*

* @ param conn

* @ return

, /

Private boolean isValid (final Connection conn) {

Try {

If (conn = = null | | conn.isClosed ()) {

Return false

}

} catch (SQLException e) {

If (LOG.isInfoEnabled ()) {

LOG.info ("an exception occurred while determining whether a connection is available")

}

E.printStackTrace ()

}

Return true

}

/ * *

* destroy the connection pool

, /

Public synchronized void destroy () {

/ * *

* destroy the free connection pool

, /

For (Connection conn: freeConnection) {

Try {

If (isValid (conn)) {

Conn.close ()

}

} catch (SQLException e) {

E.printStackTrace ()

}

}

/ * *

* destroy a custom connection pool

, /

For (Connection conn: activeConnection) {

Try {

If (isValid (conn)) {

Conn.close ()

}

} catch (SQLException e) {

E.printStackTrace ()

}

}

IsActive = false

ContActive = 0

}

/ * *

* connection pool status

*

* @ return

, /

Public boolean isActive () {

Return isActive

}

/ * *

* check the connection pool regularly

, /

Public void cheackPool () {

If (dbBean.isCheakPool ()) {

If (LOG.isInfoEnabled ()) {

LOG.info ("Open the connection pool timing check task. The current set check frequency is" + dbBean.getPeriodCheck () + "and the check interval is" + dbBean.getLazyCheck ()). "

}

/ / start a timer-like clock task to detect the current thread in use

New Timer () .schedule (new TimerTask () {

@ Override

Public void run () {

/ / 1. Check the connection status in the thread

/ / 2. Minimum and maximum number of connections in connection pool

/ / 3. Check other states, because there are several thread-managed classes that need to be written here, which will not be added for the time being

If (LOG.isInfoEnabled ()) {

LOG.info ("empty line pool connections:" + freeConnection.size ())

LOG.info ("active connections::" + activeConnection.size ())

LOG.info ("Total connections:" + contActive)

}

}

}, dbBean.getLazyCheck (), dbBean.getPeriodCheck ()

}

}

}

/ * * ConnectionPoolManager*/

/ *

* Copyright 2000-2020 YGSoft.Inc All Rights Reserved.

, /

Package com.ygsoft.gris.mapp.materialmanage.impl.util

Import java.sql.Connection

Import java.sql.SQLException

Import java.util.Hashtable

Import com.ygsoft.ecp.service.log.EcpLogFactory

Import com.ygsoft.ecp.service.log.IEcpLog

/ * *

* connection pool management.

*

* @ author mapengfei

* @ version 1.0.0 May 12, 2016

* @ see

* @ since JDK 1.5.0

, /

Public class ConnectionPoolManager {

/ * *

* connection pool storage

, /

Public Hashtable pools = new Hashtable ()

/ * *

* Log

, /

Private static final IEcpLog LOG = EcpLogFactory.getLog (ConnectionPoolManager.class)

/ * *

* Constructor

, /

Private ConnectionPoolManager () {

Init ()

}

/ * *

* singleton implementation

*

* @ return

, /

Public static ConnectionPoolManager getInstance () {

Return Singtonle.INSTANCE; / / start singleton mode

}

/ * *

*

* enable singleton

*

* @ author mapengfei

* @ version 1.0.0 May 12, 2016

* @ see

* @ since JDK 1.5.0

, /

Private static class Singtonle {

Private static ConnectionPoolManager INSTANCE = new ConnectionPoolManager ()

}

/ * *

* initialize all connection pooling

, /

Public void init () {

/ * *

* put connection pooling into management

, /

For (int I = 0; I

< DBInitInfo.beans.size(); i++) { DBbean bean = DBInitInfo.beans.get(i); ConnectionPool pool = new ConnectionPool(bean); if (pool != null) { pools.put(bean.getPoolName(), pool); // 写入集合 if (LOG.isInfoEnabled()) { LOG.info("信息:初始化连接池成功 ->

"+ bean.getPoolName ())

}

}

}

}

/ * *

* obtain the connection according to the name of the connection pool

*

* @ param poolName

* connection pool name

* @ return

, /

Public Connection getConnection (final String poolName) {

Connection conn = null

If (pools.size () > 0 & & pools.containsKey (poolName)) {

Conn = getPool (poolName). GetConnection ()

} else {

If (LOG.isInfoEnabled ()) {

LOG.info ("Error: the link was not found->" + poolName)

}

}

Return conn

}

/ * *

* close and recycle the connection

*

* @ param poolName

* connection pool name

* @ param conn

* Link

, /

Public void closeConnection (final String poolName, final Connection conn) {

If (LOG.isInfoEnabled ()) {

LOG.info ("start the link off recycling mechanism to close the link for the connection pool named" + poolName+ "+ conn)

}

ConnectionPool pool = getPool (poolName)

Try {

If (pool! = null) {

Pool.releaseConn (conn)

}

} catch (SQLException e) {

If (LOG.isInfoEnabled ()) {

LOG.info ("connection pool destroyed")

}

E.printStackTrace ()

}

}

/ * *

* clear the connection pool

*

* @ param poolName

* connection pool name

, /

Public void destroy (final String poolName) {

ConnectionPool pool = getPool (poolName)

If (pool! = null) {

Pool.destroy ()

}

}

/ * *

* get connection pooling

*

* @ param poolName

* connection pool name

* @ return

, /

Public ConnectionPool getPool (final String poolName) {

ConnectionPool pool = null

If (pools.size () > 0) {

Pool = pools.get (poolName)

}

Return pool

}

}

/ * * DBbean*/

Package com.ygsoft.gris.mapp.materialmanage.impl.util

/ * *

* this is an externally configurable connection pool property

* external configuration can be allowed, with default values

* @ author Ran

*

, /

Public class DBbean {

/ / connection Pool Properties

Private String driverName

Private String url

Private String userName

Private String password

Name of the private String poolName; / / link pool

Private int minConnections = 1; / / Free pool, minimum number of connections

Private int maxConnections = 10; / / Free pool, maximum number of connections

Private int initConnections = 5 handle / number of initialized connections

Private long connTimeOut = 1000 / frequency of repeated acquisition of connection

Private int maxActiveConnections = 10 / maximum number of connections allowed, corresponding to the database

Private long connectionTimeOut = 1000minutes 60ram / connection timeout. Default is 1 minute.

Private boolean isCurrentConnection = true; / / whether to obtain the current connection, default true

Private boolean isCheakPool = true; / / whether to check the connection pool regularly

Private long lazyCheck = 1000 minutes 60 ram / how long after the delay to start the check

Private long periodCheck = 10000060ram / check frequency

/ * *

*

* @ param driverName driver name

* @ param url

* @ param userName

* @ param password

* @ param poolName connection pool name

, /

Public DBbean (final String driverName, final String url, final String userName,final String password, final String poolName) {

Super ()

This.driverName = driverName

This.url = url

This.userName = userName

This.password = password

This.poolName = poolName

}

Public DBbean () {

}

Public String getDriverName () {

If (driverName = = null) {

DriverName = this.getDriverName () + "_" + this.getUrl ()

}

Return driverName

}

/ * *

* get url.

* @ return the url

, /

Public String getUrl () {

Return url

}

/ * *

* set url.

* @ param newUrl the url to set

, /

Public void setUrl (final String newUrl) {

Url = newUrl

}

/ * *

* get userName.

* @ return the userName

, /

Public String getUserName () {

Return userName

}

/ * *

* set userName.

* @ param newUserName the userName to set

, /

Public void setUserName (final String newUserName) {

UserName = newUserName

}

/ * *

* get password.

* @ return the password

, /

Public String getPassword () {

Return password

}

/ * *

* set password.

* @ param newPassword the password to set

, /

Public void setPassword (final String newPassword) {

Password = newPassword

}

/ * *

* get poolName.

* @ return the poolName

, /

Public String getPoolName () {

Return poolName

}

/ * *

* set poolName.

* @ param newPoolName the poolName to set

, /

Public void setPoolName (final String newPoolName) {

PoolName = newPoolName

}

/ * *

* get minConnections.

* @ return the minConnections

, /

Public int getMinConnections () {

Return minConnections

}

/ * *

* set minConnections.

* @ param newMinConnections the minConnections to set

, /

Public void setMinConnections (final int newMinConnections) {

MinConnections = newMinConnections

}

/ * *

* get maxConnections.

* @ return the maxConnections

, /

Public int getMaxConnections () {

Return maxConnections

}

/ * *

* set maxConnections.

* @ param newMaxConnections the maxConnections to set

, /

Public void setMaxConnections (final int newMaxConnections) {

MaxConnections = newMaxConnections

}

/ * *

* get initConnections.

* @ return the initConnections

, /

Public int getInitConnections () {

Return initConnections

}

/ * *

* set initConnections.

* @ param newInitConnections the initConnections to set

, /

Public void setInitConnections (final int newInitConnections) {

InitConnections = newInitConnections

}

/ * *

* get connTimeOut.

* @ return the connTimeOut

, /

Public long getConnTimeOut () {

Return connTimeOut

}

/ * *

* set connTimeOut.

* @ param newConnTimeOut the connTimeOut to set

, /

Public void setConnTimeOut (final long newConnTimeOut) {

ConnTimeOut = newConnTimeOut

}

/ * *

* get maxActiveConnections.

* @ return the maxActiveConnections

, /

Public int getMaxActiveConnections () {

Return maxActiveConnections

}

/ * *

* set maxActiveConnections.

* @ param newMaxActiveConnections the maxActiveConnections to set

, /

Public void setMaxActiveConnections (final int newMaxActiveConnections) {

MaxActiveConnections = newMaxActiveConnections

}

/ * *

* get connectionTimeOut.

* @ return the connectionTimeOut

, /

Public long getConnectionTimeOut () {

Return connectionTimeOut

}

/ * *

* set connectionTimeOut.

* @ param newConnectionTimeOut the connectionTimeOut to set

, /

Public void setConnectionTimeOut (final long newConnectionTimeOut) {

ConnectionTimeOut = newConnectionTimeOut

}

/ * *

* get isCurrentConnection.

* @ return the isCurrentConnection

, /

Public boolean isCurrentConnection () {

Return isCurrentConnection

}

/ * *

* set isCurrentConnection.

* @ param newIsCurrentConnection the isCurrentConnection to set

, /

Public void setCurrentConnection (final boolean newIsCurrentConnection) {

IsCurrentConnection = newIsCurrentConnection

}

/ * *

* get isCheakPool.

* @ return the isCheakPool

, /

Public boolean isCheakPool () {

Return isCheakPool

}

/ * *

* set isCheakPool.

* @ param newIsCheakPool the isCheakPool to set

, /

Public void setCheakPool (final boolean newIsCheakPool) {

IsCheakPool = newIsCheakPool

}

/ * *

* get lazyCheck.

* @ return the lazyCheck

, /

Public long getLazyCheck () {

Return lazyCheck

}

/ * *

* set lazyCheck.

* @ param newLazyCheck the lazyCheck to set

, /

Public void setLazyCheck (final long newLazyCheck) {

LazyCheck = newLazyCheck

}

/ * *

* get periodCheck.

* @ return the periodCheck

, /

Public long getPeriodCheck () {

Return periodCheck

}

/ * *

* set periodCheck.

* @ param newPeriodCheck the periodCheck to set

, /

Public void setPeriodCheck (final long newPeriodCheck) {

PeriodCheck = newPeriodCheck

}

/ * *

* set driverName.

* @ param newDriverName the driverName to set

, /

Public void setDriverName (final String newDriverName) {

DriverName = newDriverName

}

}

/ * DBInitInfo*/

/ *

* Copyright 2000-2020 YGSoft.Inc All Rights Reserved.

, /

Package com.ygsoft.gris.mapp.materialmanage.impl.util

Import java.util.ArrayList

Import java.util.List

Import com.ygsoft.gris.mapp.materialmanage.impl.ext.config.BaseConfig

/ * *

* initialize and simulate loading all configuration files.

* @ author mapengfei

* @ version 1.0.0 May 12, 2016

* @ see

* @ since JDK 1.5.0

, /

Public class DBInitInfo {

Public static List beans = null

Static {

Beans = new ArrayList ()

/ / the data can be obtained from configuration files such as xml.

/ / for the test, I will write directly to death here.

DBbean beanOracle = new DBbean ()

BeanOracle.setDriverName (BaseConfig.get ("DriverName"))

BeanOracle.setUrl (BaseConfig.get ("JdbcUrl"))

BeanOracle.setMinConnections (Integer.valueOf (BaseConfig.get ("MinConnections")

BeanOracle.setMaxConnections (Integer.valueOf (BaseConfig.get ("MaxConnections")

BeanOracle.setPoolName (BaseConfig.get ("PoolName"))

BeanOracle.setUserName (BaseConfig.get ("dbusername"))

BeanOracle.setPassword (BaseConfig.get ("dbpassword"))

Beans.add (beanOracle)

}

}

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.

Views: 0

*The comments in the above article only represent the author's personal views and do not represent the views and positions of this website. If you have more insights, please feel free to contribute and share.

Share To

Database

Wechat

© 2024 shulou.com SLNews company. All rights reserved.

12
Report