jdbc之运用占位符的增删改查

jdbc之使用占位符的增删改查

1. package com.hanchao.jdbc;
2. import java.sql.Connection;import java.sql.DriverManager;
3. import java.sql.PreparedStatement;import java.sql.ResultSet;
4. /**
5. * jdbc学习总结二 * @author hanlw
6. * 2012-07-09 */
7. public class TestJdbcNew {
8.     /**      * 上一篇文章，我们对JDBC有了初步的了解，并且知道了如何使用JDBC了。
9.      * 但是，那只是JDBC的了解性操作实例。实际开发中，我们是不能那么玩的！！     *
10.      * ★下面我们学习一下：JDBC的占位符的使用，以后写程序建议都要这么玩的！！     *
11.      * 注意事项：我们的异常应该捕获；而不是抛出来啊！！     *
12.      * SQLException是非运行时异常，必须要捕获或者向上抛出！！★     */
13.          public staticvoid main(String[] args) throws Exception {
14.         /**          * 1.jdbc对Mysql的insert操作
15.          */ //      insert("cherry","shanghai");
16.                  /**
17.          * 2.jdbc对mysql的update操作         */
18. //      update("update",12);        
19.         /**          * 3.jdbc对mysql的delete操作
20.          */ //      delete(12);
21.                  /**
22.          * 4.jdbc对mysql的retrieve 操作         */
23.         retrieve(15);     }
24.          /**
25.      * jdbc对mysql的insert操作      *
26.      * @param username 用户名      * @param address 地址
27.      */     public staticvoid insert(String username,String address)throws Exception {
28.         Class.forName("com.mysql.jdbc.Driver");        Connection con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydb","root","root");
29.                  //注意下面几行★
30.         String sql = "insert into t_user(username,address) values(?,?)";//★         PreparedStatement sta = con.prepareStatement(sql);
31.         sta.setString(1, username);        sta.setString(2, address);
32.                  int rows = sta.executeUpdate();
33.         if(rows > 0) {             System.out.println("operate successfully!");
34.         }         sta.close();
35.         con.close();     }
36.          /**
37.      * jdbc对mysql的update操作      *
38.      * @param address 地址      * @param id 主键值
39.      * @throws Exception      */
40.     public staticvoid update(String address,int id)throws Exception {         Class.forName("com.mysql.jdbc.Driver");
41.         Connection con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydb","root","root");        
42.         //★注意下面几行代码         String sql  = "update t_user set address=? where id=?";
43.         PreparedStatement sta = con.prepareStatement(sql);         sta.setString(1, address);
44.         sta.setInt(2, id);        
45.         int rows = sta.executeUpdate();        if(rows > 0) {
46.             System.out.println("operate successfully");        }
47.         sta.close();         con.close();
48.              }
49.          /**
50.      * jdbc对mysql的删除操作      *
51.      * @param id      * @throws Exception
52.      */     public staticvoid delete(int id)throws Exception {
53.         Class.forName("com.mysql.jdbc.Driver");        Connection con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydb","root","root");
54.                  //★注意点
55.         String sql = "delete from t_user where id=?";        PreparedStatement sta = con.prepareStatement(sql);
56.         sta.setInt(1, id);        
57.         int rows = sta.executeUpdate();        if(rows > 0) {
58.             System.out.println("operate successfully!!");        }
59.         sta.close();         con.close();
60.     }     
61.     /**      * jdbc对mysql的retrieve操作
62.      *      * @param id
63.      * @throws Exception      */
64.     public staticvoid retrieve(int id)throws Exception {         Class.forName("com.mysql.jdbc.Driver");
65.         Connection con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydb","root","root");        
66.         //注意★         String sql = "select id,username,address from t_user where id=?";
67.         PreparedStatement sta = con.prepareStatement(sql);         sta.setInt(1, id);
68.                  ResultSet rs = sta.executeQuery();
69.         //注意：当现实一条记录时：while可以换成if。★        if(rs.next()) {
70.             int did = rs.getInt("id");            String username = rs.getString("username");
71.             String address = rs.getString("address");            System.out.println(did + "\t" + username +"\t" + address);
72.         }         
73.         rs.close();         sta.close();
74.         con.close();     }
75.      }