public class DBOpenHelper {
 
  private static String driver = "com.mysql.jdbc.Driver";//MySQL 驅(qū)動(dòng)
  private static String url = "jdbc:mysql://IP:3306/數(shù)據(jù)庫(kù)";//MYSQL數(shù)據(jù)庫(kù)連接Url
  private static String user = "root";//用戶名
  private static String password = "root";//密碼
 
  /**
   * 連接數(shù)據(jù)庫(kù)
   * */
 
  public static Connection getConn(){
    Connection conn = null;
    try {
      Class.forName(driver);//獲取MYSQL驅(qū)動(dòng)
      conn = (Connection) DriverManager.getConnection(url, user, password);//獲取連接
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
    } catch (SQLException e) {
      e.printStackTrace();
    }
    return conn;
  }
 
  /**
   * 關(guān)閉數(shù)據(jù)庫(kù)
   * */
 
  public static void closeAll(Connection conn, PreparedStatement ps){
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    if (ps != null) {
      try {
        ps.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
 
  }
 
  /**
   * 關(guān)閉數(shù)據(jù)庫(kù)
   * */
 
  public static void closeAll(Connection conn, PreparedStatement ps, ResultSet rs){
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    if (ps != null) {
      try {
        ps.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    if (rs != null) {
      try {
        rs.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
 
}

public class DBService {
 
  private Connection conn=null; //打開(kāi)數(shù)據(jù)庫(kù)對(duì)象
  private PreparedStatement ps=null;//操作整合sql語(yǔ)句的對(duì)象
  private ResultSet rs=null;//查詢結(jié)果的集合
 
  //DBService 對(duì)象
  public static DBService dbService=null;
 
  /**
   * 構(gòu)造方法 私有化
   * */
 
  private DBService(){
 
  }
 
  /**
   * 獲取MySQL數(shù)據(jù)庫(kù)單例類對(duì)象
   * */
 
  public static DBService getDbService(){
    if(dbService==null){
      dbService=new DBService();
    }
    return dbService;
  }
 
 
  /**
   * 獲取要發(fā)送短信的患者信息  查
   * */
 
  public List<User> getUserData(){
    //結(jié)果存放集合
    List<User> list=new ArrayList<User>();
    //MySQL 語(yǔ)句
    String sql="select * from user";
    //獲取鏈接數(shù)據(jù)庫(kù)對(duì)象
    conn= DBOpenHelper.getConn();
    try {
      if(conn!=null&&(!conn.isClosed())){
        ps= (PreparedStatement) conn.prepareStatement(sql);
        if(ps!=null){
          rs= ps.executeQuery();
          if(rs!=null){
            while(rs.next()){
              User u=new User();
              u.setId(rs.getString("id"));
              u.setName(rs.getString("name"));
              u.setPhone(rs.getString("phone"));
              u.setContent(rs.getString("content"));
              u.setState(rs.getString("state"));
              list.add(u);
            }
          }
        }
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
    DBOpenHelper.closeAll(conn,ps,rs);//關(guān)閉相關(guān)操作
    return list;
  }
 
  /**
   * 修改數(shù)據(jù)庫(kù)中某個(gè)對(duì)象的狀態(tài)  改
   * */
 
  public int updateUserData(String phone){
    int result=-1;
    if(!StringUtils.isEmpty(phone)){
      //獲取鏈接數(shù)據(jù)庫(kù)對(duì)象
      conn= DBOpenHelper.getConn();
      //MySQL 語(yǔ)句
      String sql="update user set state=? where phone=?";
      try {
        boolean closed=conn.isClosed();
        if(conn!=null&&(!closed)){
          ps= (PreparedStatement) conn.prepareStatement(sql);
          ps.setString(1,"1");//第一個(gè)參數(shù)state 一定要和上面SQL語(yǔ)句字段順序一致
          ps.setString(2,phone);//第二個(gè)參數(shù) phone 一定要和上面SQL語(yǔ)句字段順序一致
          result=ps.executeUpdate();//返回1 執(zhí)行成功
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    DBOpenHelper.closeAll(conn,ps);//關(guān)閉相關(guān)操作
    return result;
  }
 
  /**
   * 批量向數(shù)據(jù)庫(kù)插入數(shù)據(jù)  增
   * */
 
  public int insertUserData(List<User> list){
    int result=-1;
    if((list!=null)&&(list.size()>0)){
      //獲取鏈接數(shù)據(jù)庫(kù)對(duì)象
      conn= DBOpenHelper.getConn();
      //MySQL 語(yǔ)句
      String sql="INSERT INTO user (name,phone,content,state) VALUES (?,?,?,?)";
      try {
        boolean closed=conn.isClosed();
        if((conn!=null)&&(!closed)){
          for(User user:list){
            ps= (PreparedStatement) conn.prepareStatement(sql);
            String name=user.getName();
            String phone=user.getPhone();
            String content=user.getContent();
            String state=user.getState();
            ps.setString(1,name);//第一個(gè)參數(shù) name 規(guī)則同上
            ps.setString(2,phone);//第二個(gè)參數(shù) phone 規(guī)則同上
            ps.setString(3,content);//第三個(gè)參數(shù) content 規(guī)則同上
            ps.setString(4,state);//第四個(gè)參數(shù) state 規(guī)則同上
            result=ps.executeUpdate();//返回1 執(zhí)行成功
          }
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    DBOpenHelper.closeAll(conn,ps);//關(guān)閉相關(guān)操作
    return result;
  }
 
  
  /**
   * 刪除數(shù)據(jù) 刪
   * */
 
  public int delUserData(String phone){
    int result=-1;
    if((!StringUtils.isEmpty(phone))&&(PhoneNumberUtils.isMobileNumber(phone))){
      //獲取鏈接數(shù)據(jù)庫(kù)對(duì)象
      conn= DBOpenHelper.getConn();
      //MySQL 語(yǔ)句
      String sql="delete from user where phone=?";
      try {
        boolean closed=conn.isClosed();
        if((conn!=null)&&(!closed)){
          ps= (PreparedStatement) conn.prepareStatement(sql);
          ps.setString(1, phone);
          result=ps.executeUpdate();//返回1 執(zhí)行成功
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    DBOpenHelper.closeAll(conn,ps);//關(guān)閉相關(guān)操作
    return result;
  }
 
}