添加车载上报停靠站数据库配置文件

zlz
1 parent 541bd234
Showing 3 changed files with 149 additions and 4 deletions
src/main/java/com/bsth/service/traffic/impl/VehicleInoutStopServiceImpl.java
src/main/java/com/bsth/util/db/DBUtils_traffic.java
src/main/resources/traffic-jdbc.properties
@@ -5,10 +5,9 @@ import com.bsth.service.impl.BaseServiceImpl;
 import com.bsth.service.impl.TrafficManageServiceImpl;
 import com.bsth.service.traffic.VehicleInoutStopService;
 import com.bsth.util.DateUtils;
-import com.bsth.util.db.DBUtils_MS;
+import com.bsth.util.db.DBUtils_traffic;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Service;
  
@@ -76,7 +75,7 @@ public class VehicleInoutStopServiceImpl extends BaseServiceImpl&lt;VehicleInoutSto
 	 * @return
 	 */
 	public List<Map<String, Object>> getVehicleInoutStopByParam(Map<String,Object> map){
-		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_MS.getDataSource());
+		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_traffic.getDataSource());
 		String sql = "SELECT branche_company,company,name,shanghai_linecode,inside_code,equipment_code,car_plate," +
 				"if( service_state= 0,'营运','停运') as service_state ," +
 				"if( up_down= 0,'上行','下行') as up_down ," +
@@ -93,7 +92,7 @@ public class VehicleInoutStopServiceImpl extends BaseServiceImpl&lt;VehicleInoutSto
 	 * @return
 	 */
 	public long getVehicleInoutStopCountByParam(Map<String,Object> map){
-		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_MS.getDataSource());
+		JdbcTemplate jdbcTemp = new JdbcTemplate(DBUtils_traffic.getDataSource());
 		String sql = "SELECT count(1) COUNT FROM bsth_c_shreal" + packageParam(map,"count");
 		long result = Long.valueOf(jdbcTemp.queryForMap(sql).get("COUNT")+"");
 		logger.info("车载上报停靠站查询count-sql:"+sql);
+package com.bsth.util.db;
+
+import com.mchange.v2.c3p0.DataSources;
+import org.apache.log4j.Logger;
+
+import javax.sql.DataSource;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+
+/**
+ * 网关ms库连接池
+ * @author PanZhao
+ *
+ */
+//@Component
+public class DBUtils_traffic {
+
+	private static String url = null;
+
+	private static String username = null;
+
+	private static String pwd = null;
+
+	private static DataSource ds_pooled;
+
+	static Logger logger = Logger.getLogger(DBUtils_traffic.class);
+	
+	static {
+		Properties env = new Properties();
+
+		try {
+			env.load(DBUtils_traffic.class.getClassLoader().getResourceAsStream("traffic-jdbc.properties"));
+			// 1. 加载驱动类
+			Class.forName(env.getProperty("ms.mysql.driver"));
+
+			url = env.getProperty("ms.mysql.url");
+			username = env.getProperty("ms.mysql.username");
+			pwd = env.getProperty("ms.mysql.password");
+
+			// 设置连接数据库的配置信息
+			DataSource ds_unpooled = DataSources.unpooledDataSource(url,
+					username, pwd);
+
+			Map<String, Object> pool_conf = new HashMap<String, Object>();
+			// 设置最大连接数
+			pool_conf.put("maxPoolSize", 10);
+			
+			pool_conf.put("testConnectionOnCheckout", false);
+			//异步检测连接的有效性
+			pool_conf.put("testConnectionOnCheckin", true);
+			//30秒检测一次
+			pool_conf.put("idleConnectionTestPeriod", 30);
+			ds_pooled = DataSources.pooledDataSource(ds_unpooled, pool_conf);
+		} catch (FileNotFoundException e) {
+			logger.error(e.toString());
+			e.printStackTrace();
+		} catch (IOException e) {
+			logger.error(e.toString());
+			e.printStackTrace();
+		} catch (ClassNotFoundException e) {
+			logger.error(e.toString());
+			e.printStackTrace();
+		} catch (SQLException e) {
+			logger.error(e.toString());
+			e.printStackTrace();
+		}
+	}
+
+	/**
+	 * 获取连接对象
+	 */
+	public static Connection getConnection() throws SQLException {
+		return ds_pooled.getConnection();
+	}
+
+	/**
+	 * 释放连接池资源
+	 */
+	public static void clearup() {
+		if (ds_pooled != null) {
+			try {
+				DataSources.destroy(ds_pooled);
+			} catch (SQLException e) {
+				logger.error(e.toString());
+				e.printStackTrace();
+			}
+		}
+	}
+
+	/**
+	 * 资源关闭
+	 * 
+	 * @param rs
+	 * @param stmt
+	 * @param conn
+	 */
+	public static void close(ResultSet rs, Statement stmt, Connection conn) {
+		if (rs != null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+				logger.error(e.toString());
+				e.printStackTrace();
+			}
+		}
+
+		if (stmt != null) {
+			try {
+				stmt.close();
+			} catch (SQLException e) {
+				logger.error(e.toString());
+				e.printStackTrace();
+			}
+		}
+
+		if (conn != null) {
+			try {
+				conn.close();
+			} catch (SQLException e) {
+				logger.error(e.toString());
+				e.printStackTrace();
+			}
+		}
+	}
+
+	public static DataSource getDataSource(){
+		return ds_pooled;
+	}
+}
+#ms.mysql.driver= com.mysql.jdbc.Driver
+#ms.mysql.url= jdbc:mysql://127.0.0.1/pd_control?useUnicode=true&characterEncoding=utf-8&useSSL=false
+#ms.mysql.username= root
+#ms.mysql.password= 123456
+
+ms.mysql.driver= com.mysql.jdbc.Driver
+ms.mysql.url= jdbc:mysql://10.10.150.21:3306/ms?useUnicode=true&characterEncoding=utf-8
+ms.mysql.username= root
+ms.mysql.password= root2jsp@JSP
+