jdbc呼叫mysql儲存過程
阿新 • • 發佈:2018-11-14
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(); } }