package com.ts.dao; import java.sql.*; public class BaseDao { protected Connection conn = null; protected PreparedStatement pstmt = null; protected ResultSet rs = null; public void getConnection() { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } try { conn = DriverManager.getConnection( "jdbc:mysql://localhost:3306/ts?useUnicode=true&characterEncoding=utf-8", "root", "ok"); } catch (SQLException e) { e.printStackTrace(); } } public void closeAll() { try { if (rs != null) { rs.close(); } if (pstmt != null) { pstmt.close(); } if (conn != null) { conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } //通用增刪改 public int executeUpdateSQL(String sql, Object[] param) { int num = 0; try { getConnection(); pstmt = conn.prepareStatement(sql); if (param != null) { for (int i = 0; i < param.length; i++) { pstmt.setObject(i + 1, param[i]); } } num = pstmt.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { closeAll(); } return num; } //通用查詢 public void executeQuerySQL(String sql, Object[] param) { try { getConnection(); pstmt = conn.prepareStatement(sql); if (param != null) { for (int i = 0; i < param.length; i++) { pstmt.setObject(i + 1, param[i]); } } rs = pstmt.executeQuery(); } catch (SQLException e) { e.printStackTrace(); } } }