In addition to Weibo, there is also WeChat
Please pay attention
WeChat public account
Shulou
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.
Continue with the installation of the previous hadoop.First, install zookooper1. Decompress zookoope
"Every 5-10 years, there's a rare product, a really special, very unusual product that's the most un
© 2024 shulou.com SLNews company. All rights reserved.