历史数据存储

+driverClassName=com.mysql.cj.jdbc.Driver
+url=jdbc:mysql://rm-wz9740un21f09iokuao.mysql.rds.aliyuncs.com:3306/liu_yu_le?useUnicode=true&characterEncoding=utf8&autoReconnect=true
+username=luhui
+password=Luhui586
+#\u6700\u5927\u8FDE\u63A5\u6570\u91CF
+maxActive=100
+#\u6700\u5927\u7A7A\u95F2\u8FDE\u63A5
+maxIdle=-1
+#\u6700\u5C0F\u7A7A\u95F2\u8FDE\u63A5
+minIdle=10
+#\u8D85\u65F6\u7B49\u5F85\u65F6\u95F4\u4EE5\u6BEB\u79D2\u4E3A\u5355\u4F4D 60000\u6BEB\u79D2/1000\u7B49\u4E8E60\u79D2
+maxWait=60000
+#removeAbandoned: \u662F\u5426\u81EA\u52A8\u56DE\u6536\u8D85\u65F6\u8FDE\u63A5
+removeAbandoned=true
+#removeAbandonedTimeout: \u8D85\u65F6\u65F6\u95F4(\u4EE5\u79D2\u6570\u4E3A\u5355\u4F4D)
+removeAbandonedTimeout=120
+testOnBorrow=false
+logAbandoned=true
\ No newline at end of file

+package com.zhonglai.luhui.data.file.service.service;
+
+import com.zhonglai.db.DBFactory;
+import org.apache.commons.dbcp.BasicDataSourceFactory;
+import org.apache.commons.dbutils.QueryRunner;
+
+import javax.sql.DataSource;
+import java.io.FileInputStream;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.Properties;
+
+public class DataDBFactoryImp implements DBFactory {
+    private static DataSource ds = null;
+    private static QueryRunner runner;
+
+    public DataDBFactoryImp() {
+    }
+
+    public static Connection getConnection() {
+        try {
+            return ds.getConnection();
+        } catch (SQLException var1) {
+            var1.printStackTrace();
+            return null;
+        }
+    }
+
+    public DataSource getDataSource() {
+        return ds;
+    }
+
+    public QueryRunner getQueryRunner() {
+        return runner;
+    }
+
+    static {
+        try {
+            if (null == ds) {
+                String path = System.getProperty("user.dir") + "/configs/";
+                Properties p = new Properties();
+                p.load(new FileInputStream(path + "sensor_dbcpconfig.properties"));
+                ds = BasicDataSourceFactory.createDataSource(p);
+            }
+        } catch (Exception var2) {
+            var2.printStackTrace();
+        }
+
+        if (null == runner) {
+            runner = new QueryRunner(ds);
+        }
+
+    }
+}

+package com.zhonglai.luhui.data.file.service.service;
+
+import com.zhonglai.dao.BaseDao;
+
+/**
+ * 数据服务
+ */
+public class DataService {
+    private static BaseDao baseDao = new BaseDao(new DataDBFactoryImp());
+}