public static void updateMtBeginTimeIsSix() {
Connection connection = null;
CallableStatement cs = null;
try {
connection = DataSource.getInstance().getConnection();
cs = connection.prepareCall("{call update_mt_begin_time_is_six()}");
cs.execute();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (connection != null) {
connection.close();
}
if (cs != null) {
cs.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
public static void SubjectOne(String beginDateStr, String endDateStr) {
Connection connection = null;
CallableStatement cs = null;
try {
connection = DataSource.getInstance().getConnection();
cs = connection.prepareCall("{call queryDataForSubject1(?,?)}");
cs.setInt(1, Integer.parseInt(beginDateStr));
cs.setInt(2, Integer.parseInt(endDateStr));
cs.execute();
System.out.println(cs);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (connection != null) {
connection.close();
}
if (cs != null) {
cs.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
数据源c3p0
public class DataSource {
private static DataSource datasource;
private ComboPooledDataSource cpds;
private DataSource() throws IOException, SQLException, PropertyVetoException {
cpds = new ComboPooledDataSource();
cpds.setDriverClass("com.mysql.jdbc.Driver");
cpds.setJdbcUrl("jdbc:mysql://localhost:3306/stopsix_two_phase");
cpds.setUser("root");
cpds.setPassword("root");
cpds.setMinPoolSize(5);
cpds.setAcquireIncrement(5);
cpds.setMaxPoolSize(20);
}
public static DataSource getInstance() throws IOException, SQLException, PropertyVetoException {
if (datasource == null) {
datasource = new DataSource();
return datasource;
} else {
return datasource;
}
}
public Connection getConnection() throws SQLException {
return this.cpds.getConnection();
}
}