原生JDBC

  1 public static void main(String[] args) throws Exception {
  2         //1.注册驱动
  3         Class.forName("com.mysql.jdbc.Driver");
  4         //2.获取数据库连接
  5         String url = "jdbc:mysql://localhost:3306/mybase4";
  6         String user = "root";
  7         String password = "root"; 
  8         Connection conn = DriverManager.getConnection(url, user, password);
  9         //3.获取执行者对象
 10         Statement stat = conn.createStatement();
 11         //调用更新数据的方法
 12         //update(stat);
 13         //调用删除数据的方法
 14         //delete(stat);
 15         //调用增加数据的方法
 16         //insert(stat);
 17         //调用查询数据的方法
 18         select(stat);
 19         //6.释放资源
 20         stat.close();
 21         conn.close();
 22     }
 23 
 24     /*
 25      * 使用JDBC技术,查询数据库中表的数据
 26      */
 27     private static void select(Statement stat) throws Exception {
 28         //拼接sql语句
 29         String sql = "SELECT * FROM category";
 30         /*
 31          * 4.执行sql语句
 32          * 使用Statement中的方法
 33          * ResultSet executeQuery(String sql) 执行给定的 SQL 语句，该语句返回单个 ResultSet 对象。 
 34          * 返回值ResultSet标准接口的实现类对象,实现类对象由mysql驱动提供,可以使用ResultSet接口接收
 35          */
 36         ResultSet rs = stat.executeQuery(sql);
 37         System.out.println(rs);//com.mysql.jdbc.JDBC4ResultSet@1acb189
 38         /*
 39          * 5.处理结果
 40          * ResultSet中有一个方法
 41          * boolean next() 将光标从当前位置向前移一行。
 42          * 如果新的当前行有效，则返回 true；如果不存在下一行，则返回 false 
 43          * 如果有结果集返回true,若果没有结果集返回false
 44          * 相当于迭代器中的hasNext方法
 45          */
 46         while(rs.next()){
 47             /*
 48              * next返回true,有结果集
 49              * 取出结果集
 50              * 使用ResultSet中的方法getXXX(参数);
 51              * 参数:
 52              *     int columnIndex:列所在的索引,从1开始
 53              *     String columnLabel:列名
 54              * 注意:
 55              *     如果使用getInt,getDouble指定数据类型的方法,返回值就是对应的数据类型
 56              *     如果使用getObject方法返回值是object类型(只是打印可用)
 57              * 如果使用getString方法返回值是String类型
 58              */
 59             /*int i1 = rs.getInt(1);
 60             String s2 = rs.getString(2);
 61             System.out.println(i1+"\t"+s2);*/
 62             
 63             //System.out.println(rs.getObject(1)+"\t"+rs.getObject(2));
 64             System.out.println(rs.getObject("cid")+"\t"+rs.getObject("cname"));
 65             //5.释放资源
 66             rs.close();
 67         }
 68     }
 69 
 70     /*
 71      * 使用JDBC技术,对数据库中的表数据进行增加
 72      */
 73     private static void insert(Statement stat) throws SQLException {
 74         //拼接sql语句
 75         String sql = "INSERT INTO category(cname) VALUES('玩具')";
 76         //4.执行sql语句
 77         int row = stat.executeUpdate(sql);
 78         //5.处理结果
 79         if(row>0){
 80             System.out.println("增加数据成功!");
 81         }else{
 82             System.out.println("增加数据失败!");
 83         }
 84         
 85     }
 86 
 87     /*
 88      * 使用JDBC技术,对数据库中的表数据进行删除
 89      */
 90     private static void delete(Statement stat) throws Exception {
 91         //拼接sql语句
 92         String sql = "DELETE FROM category WHERE cid=5";
 93         //4.执行sql语句
 94         int row = stat.executeUpdate(sql);
 95         //5.处理结果
 96         if(row>0){
 97             System.out.println("删除数据成功!");
 98         }else{
 99             System.out.println("删除数据失败!");
100         }
101     }
102 
103     /*
104      * 使用JDBC技术,对数据库中的表数据进行更新
105      */
106     private static void update(Statement stat) throws Exception {
107         //拼接sql语句
108         String sql = "UPDATE category SET cname='鞋帽' WHERE cid=6";
109         //4.执行sql语句
110         int row = stat.executeUpdate(sql);
111         //5.处理结果
112         if(row>0){
113             System.out.println("更新数据成功!");
114         }else{
115             System.out.println("更新数据失败!");
116         }
117     }

 1 JDBC工具类
 2 “获得数据库连接”操作，将在以后的增删改查所有功能中都存在，可以封装工具类JDBCUtils。提供获取连接对象的方法，从而达到代码的重复利用。
 3 代码演示:
 4 public class JDBCUtils {
 5     
 6     //私有构造方法,防止外界创建对象调用方法
 7     private JDBCUtils() {
 8     }
 9     
10     //定义Connectionn变量
11     private static Connection conn;
12     
13     //保证代码只执行一次,可以放入静态代码块中
14     static{
15         try {
16             //注册驱动
17             Class.forName("com.mysql.jdbc.Driver");
18             //获取连接
19             String url="jdbc:mysql://127.0.0.1:3306/mybase4";
20             String user="root";
21             String password = "root";
22             conn = DriverManager.getConnection(url, user, password);
23         } catch (Exception e) {
24             //注意,如果连接数据库失败,停止程序
25             throw new RuntimeException(e+"连接数据库失败");
26         }
27     }
28     
29     //创建一个静态方法,获取数据库连接对象,并返回
30     public static Connection getConnection(){
31         return conn;
32     }
33     
34     /*
35      * 创建一个静态方法,对资源进行释放
36      * ResultSet rs
37      * Statement stat
38      * Connection conn
39      */
40     public static void close(ResultSet rs,Statement stat,Connection conn){
41         try {
42             if(rs!=null){
43                 rs.close();
44             }
45         } catch (SQLException e) {
46             e.printStackTrace();
47         }
48         try {
49             if(stat!=null){
50                 stat.close();
51             }
52         } catch (SQLException e) {
53             e.printStackTrace();
54         }
55         try {
56             if(conn!=null){
57                 conn.close();
58             }
59         } catch (SQLException e) {
60             e.printStackTrace();
61         }
62     }
63 }