码迷,mamicode.com
首页 > 数据库 > 详细

JDBC学习入门

时间:2016-08-16 23:52:38      阅读:294      评论:0      收藏:0      [点我收藏+]

标签:

一、JDBC相关概念介绍

1.1、数据库驱动

  这里的驱动的概念和平时听到的那种驱动的概念是一样的,比如平时购买的声卡,网卡直接插到计算机上面是不能用的,必须要安装相应的驱动程序之后才能够使用声卡和网卡,同样道理,我们安装好数据库之后,我们的应用程序也是不能直接使用数据库的,必须要通过相应的数据库驱动程序,通过驱动程序去和数据库打交道,如下所示:

  技术分享

1.2、JDBC介绍

  SUN公司为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范(接口),称之为JDBC。这套接口由数据库厂商去实现,这样,开发人员只需要学习jdbc接口,并通过jdbc加载具体的驱动,就可以操作数据库。

如下图所示:

  技术分享

  JDBC全称为:Java Data Base Connectivity(java数据库连接),它主要由接口组成。
  组成JDBC的2个包:
   java.sql
   javax.sql
  开发JDBC应用需要以上2个包的支持外,还需要导入相应JDBC的数据库实现(即数据库驱动)。

 二、编写JDBC程序

2.1、搭建实验环境    

  1、在mysql中创建一个库,并创建user表和插入表的数据。

  SQL脚本如下:

 1 create database jdbcStudy character set utf8 collate utf8_general_ci;
 2 
 3 use jdbcStudy;
 4 
 5 create table users(
 6     id int primary key,
 7     name varchar(40),
 8     password varchar(40),
 9     email varchar(60),
10     birthday date
11 );
12 
13 insert into users(id,name,password,email,birthday) values(1,‘zhansan‘,‘123456‘,‘zs@sina.com‘,‘1980-12-04‘);
14 insert into users(id,name,password,email,birthday) values(2,‘lisi‘,‘123456‘,‘lisi@sina.com‘,‘1981-12-04‘);
15 insert into users(id,name,password,email,birthday) values(3,‘wangwu‘,‘123456‘,‘wangwu@sina.com‘,‘1979-12-04‘);

  2、新建一个Java工程,并导入数据驱动。
  技术分享

  3、编写程序从user表中读取数据,并打印在命令行窗口中。
  具体代码如下:

 1 package me.gacl.demo;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.ResultSet;
 5 import java.sql.Statement;
 6 
 7 public class JdbcFirstDemo {
 8 
 9     public static void main(String[] args) throws Exception {
10         //要连接的数据库URL
11         String url = "jdbc:mysql://localhost:3306/jdbcStudy";
12         //连接的数据库时使用的用户名
13         String username = "root";
14         //连接的数据库时使用的密码
15         String password = "XDP";
16         
17         //1.加载驱动
18         //DriverManager.registerDriver(new com.mysql.jdbc.Driver());不推荐使用这种方式来加载驱动
19         Class.forName("com.mysql.jdbc.Driver");//推荐使用这种方式来加载驱动
20         //2.获取与数据库的链接
21         Connection conn = DriverManager.getConnection(url, username, password);
22         
23         //3.获取用于向数据库发送sql语句的statement
24         Statement st = conn.createStatement();
25         
26         String sql = "select id,name,password,email,birthday from users";
27         //4.向数据库发sql,并获取代表结果集的resultset
28         ResultSet rs = st.executeQuery(sql);
29         
30         //5.取出结果集的数据
31         while(rs.next()){
32             System.out.println("id=" + rs.getObject("id"));
33             System.out.println("name=" + rs.getObject("name"));
34             System.out.println("password=" + rs.getObject("password"));
35             System.out.println("email=" + rs.getObject("email"));
36             System.out.println("birthday=" + rs.getObject("birthday"));
37         }
38         
39         //6.关闭链接,释放资源
40         rs.close();
41         st.close();
42         conn.close();
43     }
44 }

运行结果如下:

  技术分享

2.2、DriverManager类讲解

  Jdbc程序中的DriverManager用于加载驱动,并创建与数据库的链接,这个API的常用方法:

  1. DriverManager.registerDriver(new Driver())
  2. DriverManager.getConnection(url, user, password),

  注意:在实际开发中并不推荐采用registerDriver方法注册驱动。原因有二:
    1、查看Driver的源代码可以看到,如果采用此种方式,会导致驱动程序注册两次,也就是在内存中会有两个Driver对象。
    2、程序依赖mysql的api,脱离mysql的jar包,程序将无法编译,将来程序切换底层数据库将会非常麻烦。

  推荐方式:Class.forName("com.mysql.jdbc.Driver");
  采用此种方式不会导致驱动对象在内存中重复出现,并且采用此种方式,程序仅仅只需要一个字符串,不需要依赖具体的驱动,使程序的灵活性更高。

2.3、数据库URL讲解

  URL用于标识数据库的位置,通过URL地址告诉JDBC程序连接哪个数据库,URL的写法为:

  技术分享

  常用数据库URL地址的写法:

  • Oracle写法:jdbc:oracle:thin:@localhost:1521:sid
  • SqlServer写法:jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
  • MySql写法:jdbc:mysql://localhost:3306/sid

  如果连接的是本地的Mysql数据库,并且连接使用的端口是3306,那么的url地址可以简写为: jdbc:mysql:///数据库

2.4、Connection类讲解

  Jdbc程序中的Connection,它用于代表数据库的链接,Collection是数据库编程中最重要的一个对象,客户端与数据库所有交互都是通过connection对象完成的,这个对象的常用方法:

  • createStatement():创建向数据库发送sql的statement对象。
  • prepareStatement(sql) :创建向数据库发送预编译sql的PrepareSatement对象。
  • prepareCall(sql):创建执行存储过程的callableStatement对象。
  • setAutoCommit(boolean autoCommit):设置事务是否自动提交。
  • commit() :在链接上提交事务。
  • rollback() :在此链接上回滚事务。

2.5、Statement类讲解

  Jdbc程序中的Statement对象用于向数据库发送SQL语句, Statement对象常用方法:

  • executeQuery(String sql) :用于向数据发送查询语句。
  • executeUpdate(String sql):用于向数据库发送insert、update或delete语句
  • execute(String sql):用于向数据库发送任意sql语句
  • addBatch(String sql) :把多条sql语句放到一个批处理中。
  • executeBatch():向数据库发送一批sql语句执行。

2.6、ResultSet类讲解

  Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时,采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标,初始的时候,游标在第一行之前,调用ResultSet.next() 方法,可以使游标指向具体的数据行,进行调用方法获取该行的数据。

 

 

使用JDBC对数据库进行CRUD

一、statement对象介绍  

  Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改查语句即可。
  Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sql语句,executeUpdate执行完后,将会返回一个整数(即增删改语句导致了数据库几行数据发生了变化)。
  Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象

1.1、CRUD操作-create

  使用executeUpdate(String sql)方法完成数据添加操作,示例操作:

1 Statement st = conn.createStatement();
2 String sql = "insert into user(….) values(…..) "; 
3 int num = st.executeUpdate(sql);
4 if(num>0){
5     System.out.println("插入成功!!!");
6 }

1.2、CRUD操作-update

  使用executeUpdate(String sql)方法完成数据修改操作,示例操作:

1 Statement st = conn.createStatement();
2 String sql = “update user set name=‘’ where name=‘’"; 
3 int num = st.executeUpdate(sql);
4 if(num>0){
5     System.out.println(“修改成功!!!");
6 }

1.3、CRUD操作-delete

  使用executeUpdate(String sql)方法完成数据删除操作,示例操作:

1 Statement st = conn.createStatement();
2 String sql = “delete from user where id=1; 
3 int num = st.executeUpdate(sql);
4 if(num>0){
5     System.out.println(“删除成功!!!");
6 }

1.4、CRUD操作-read

  使用executeQuery(String sql)方法完成数据查询操作,示例操作:

1 Statement st = conn.createStatement();
2 String sql = “select * from user where id=1; 
3 ResultSet rs = st.executeUpdate(sql);
4 while(rs.next()){
5     //根据获取列的数据类型,分别调用rs的相应方法映射到java对象中
6 }

二、使用jdbc对数据库增删改查

2.1、搭建实验环境    

  1、在mysql中创建一个库,并创建user表和插入表的数据。

  SQL脚本如下:

 1 create database jdbcStudy;
 2 
 3 use jdbcStudy;
 4 
 5 create table users(
 6     id int primary key,
 7     name varchar(40),
 8     password varchar(40),
 9     email varchar(60),
10     birthday date
11 );

  2、新建一个JavaWeb工程,并导入MySQL数据库驱动。

  技术分享

  3、在src目录下创建一个db.properties文件,如下图所示:

  技术分享

  在db.properties中编写MySQL数据库的连接信息,代码如下所示:

1 driver=com.mysql.jdbc.Driver
2 url=jdbc:mysql://localhost:3306/jdbcStudy
3 username=root
4 password=XDP

  4、编写一个JdbcUtils工具类,用于连接数据库,获取数据库连接和释放数据库连接,代码如下:

 1 package me.gacl.utils;
 2 
 3 import java.io.InputStream;
 4 import java.sql.Connection;
 5 import java.sql.DriverManager;
 6 import java.sql.ResultSet;
 7 import java.sql.SQLException;
 8 import java.sql.Statement;
 9 import java.util.Properties;
10 
11 public class JdbcUtils {
12 
13     private static String driver = null;
14     private static String url = null;
15     private static String username = null;
16     private static String password = null;
17     
18     static{
19         try{
20             //读取db.properties文件中的数据库连接信息
21             InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
22             Properties prop = new Properties();
23             prop.load(in);
24             
25             //获取数据库连接驱动
26             driver = prop.getProperty("driver");
27             //获取数据库连接URL地址
28             url = prop.getProperty("url");
29             //获取数据库连接用户名
30             username = prop.getProperty("username");
31             //获取数据库连接密码
32             password = prop.getProperty("password");
33             
34             //加载数据库驱动
35             Class.forName(driver);
36             
37         }catch (Exception e) {
38             throw new ExceptionInInitializerError(e);
39         }
40     }
41     
42     /**
43     * @Method: getConnection
44     * @Description: 获取数据库连接对象
45     * @Anthor:孤傲苍狼
46     *
47     * @return Connection数据库连接对象
48     * @throws SQLException
49     */ 
50     public static Connection getConnection() throws SQLException{
51         return DriverManager.getConnection(url, username,password);
52     }
53     
54     /**
55     * @Method: release
56     * @Description: 释放资源,
57     *     要释放的资源包括Connection数据库连接对象,负责执行SQL命令的Statement对象,存储查询结果的ResultSet对象
58     * @Anthor:孤傲苍狼
59     *
60     * @param conn
61     * @param st
62     * @param rs
63     */ 
64     public static void release(Connection conn,Statement st,ResultSet rs){
65         if(rs!=null){
66             try{
67                 //关闭存储查询结果的ResultSet对象
68                 rs.close();
69             }catch (Exception e) {
70                 e.printStackTrace();
71             }
72             rs = null;
73         }
74         if(st!=null){
75             try{
76                 //关闭负责执行SQL命令的Statement对象
77                 st.close();
78             }catch (Exception e) {
79                 e.printStackTrace();
80             }
81         }
82         
83         if(conn!=null){
84             try{
85                 //关闭Connection数据库连接对象
86                 conn.close();
87             }catch (Exception e) {
88                 e.printStackTrace();
89             }
90         }
91     }
92 }

2.2、使用statement对象完成对数据库的CRUD操作

  测试代码如下:

  1 package me.gacl.demo;
  2 
  3 import java.sql.Connection;
  4 import java.sql.ResultSet;
  5 import java.sql.Statement;
  6 import me.gacl.utils.JdbcUtils;
  7 
  8 import org.junit.Test;
  9 
 10 /**
 11 * @ClassName: JdbcCRUDByStatement
 12 * @Description: 通过Statement对象完成对数据库的CRUD操作
 13 * @author: 孤傲苍狼
 14 * @date: 2014-9-15 下午11:22:12
 15 *
 16 */ 
 17 public class JdbcCRUDByStatement {
 18 
 19     @Test
 20     public void insert(){
 21         Connection conn = null;
 22         Statement st = null;
 23         ResultSet rs = null;
 24         try{
 25             //获取一个数据库连接
 26             conn = JdbcUtils.getConnection();
 27             //通过conn对象获取负责执行SQL命令的Statement对象
 28             st = conn.createStatement();
 29             //要执行的SQL命令
 30             String sql = "insert into users(id,name,password,email,birthday) values(3,‘白虎神皇‘,‘123‘,‘bhsh@sina.com‘,‘1980-09-09‘)";
 31             //执行插入操作,executeUpdate方法返回成功的条数
 32             int num = st.executeUpdate(sql);
 33             if(num>0){
 34                 System.out.println("插入成功!!");
 35             }
 36             
 37         }catch (Exception e) {
 38             e.printStackTrace();
 39         }finally{
 40             //SQL执行完成之后释放相关资源
 41             JdbcUtils.release(conn, st, rs);
 42         }
 43     }
 44     
 45     @Test
 46     public void delete(){
 47         Connection conn = null;
 48         Statement st = null;
 49         ResultSet rs = null;
 50         try{
 51             conn = JdbcUtils.getConnection();
 52             String sql = "delete from users where id=3";
 53             st = conn.createStatement();
 54             int num = st.executeUpdate(sql);
 55             if(num>0){
 56                 System.out.println("删除成功!!");
 57             }
 58         }catch (Exception e) {
 59             e.printStackTrace();
 60             
 61         }finally{
 62             JdbcUtils.release(conn, st, rs);
 63         }
 64     }
 65     
 66     @Test
 67     public void update(){
 68         Connection conn = null;
 69         Statement st = null;
 70         ResultSet rs = null;
 71         try{
 72             conn = JdbcUtils.getConnection();
 73             String sql = "update users set name=‘孤傲苍狼‘,email=‘gacl@sina.com‘ where id=3";
 74             st = conn.createStatement();
 75             int num = st.executeUpdate(sql);
 76             if(num>0){
 77                 System.out.println("更新成功!!");
 78             }
 79         }catch (Exception e) {
 80             e.printStackTrace();
 81             
 82         }finally{
 83             JdbcUtils.release(conn, st, rs);
 84         }
 85     }
 86     
 87     @Test
 88     public void find(){
 89         Connection conn = null;
 90         Statement st = null;
 91         ResultSet rs = null;
 92         try{
 93             conn = JdbcUtils.getConnection();
 94             String sql = "select * from users where id=3";
 95             st = conn.createStatement();
 96             rs = st.executeQuery(sql);
 97             if(rs.next()){
 98                 System.out.println(rs.getString("name"));
 99             }
100         }catch (Exception e) {
101             e.printStackTrace();
102         }finally{
103             JdbcUtils.release(conn, st, rs);
104         }
105     }
106 }

三、PreparedStatement对象介绍

  PreperedStatement是Statement的子类,它的实例对象可以通过调用Connection.preparedStatement()方法获得,相对于Statement对象而言:PreperedStatement可以避免SQL注入的问题
  Statement会使数据库频繁编译SQL,可能造成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译,从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数,允许使用占位符的形式进行替换,简化sql语句的编写

3.1、使用PreparedStatement对象完成对数据库的CRUD操作

  测试代码如下:

  1 package me.gacl.demo;
  2 
  3 import java.sql.Connection;
  4 import java.sql.PreparedStatement;
  5 import java.sql.ResultSet;
  6 import java.util.Date;
  7 import me.gacl.utils.JdbcUtils;
  8 import org.junit.Test;
  9 
 10 /**
 11 * @ClassName: JdbcCRUDByPreparedStatement
 12 * @Description: 通过PreparedStatement对象完成对数据库的CRUD操作
 13 * @author: 孤傲苍狼
 14 * @date: 2014-9-15 下午11:21:42
 15 *
 16 */ 
 17 public class JdbcCRUDByPreparedStatement {
 18 
 19     @Test
 20     public void insert(){
 21         Connection conn = null;
 22         PreparedStatement st = null;
 23         ResultSet rs = null;
 24         try{
 25             //获取一个数据库连接
 26             conn = JdbcUtils.getConnection();
 27             //要执行的SQL命令,SQL中的参数使用?作为占位符
 28             String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
 29             //通过conn对象获取负责执行SQL命令的prepareStatement对象
 30             st = conn.prepareStatement(sql);
 31             //为SQL语句中的参数赋值,注意,索引是从1开始的
 32             /**
 33              * SQL语句中各个字段的类型如下:
 34              *  +----------+-------------+
 35                 | Field    | Type        |
 36                 +----------+-------------+
 37                 | id       | int(11)     |
 38                 | name     | varchar(40) |
 39                 | password | varchar(40) |
 40                 | email    | varchar(60) |
 41                 | birthday | date        |
 42                 +----------+-------------+
 43              */
 44             st.setInt(1, 1);//id是int类型的
 45             st.setString(2, "白虎神皇");//name是varchar(字符串类型)
 46             st.setString(3, "123");//password是varchar(字符串类型)
 47             st.setString(4, "bhsh@sina.com");//email是varchar(字符串类型)
 48             st.setDate(5, new java.sql.Date(new Date().getTime()));//birthday是date类型
 49             //执行插入操作,executeUpdate方法返回成功的条数
 50             int num = st.executeUpdate();
 51             if(num>0){
 52                 System.out.println("插入成功!!");
 53             }
 54             
 55         }catch (Exception e) {
 56             e.printStackTrace();
 57         }finally{
 58             //SQL执行完成之后释放相关资源
 59             JdbcUtils.release(conn, st, rs);
 60         }
 61     }
 62     
 63     @Test
 64     public void delete(){
 65         Connection conn = null;
 66         PreparedStatement st = null;
 67         ResultSet rs = null;
 68         try{
 69             conn = JdbcUtils.getConnection();
 70             String sql = "delete from users where id=?";
 71             st = conn.prepareStatement(sql);
 72             st.setInt(1, 1);
 73             int num = st.executeUpdate();
 74             if(num>0){
 75                 System.out.println("删除成功!!");
 76             }
 77         }catch (Exception e) {
 78             e.printStackTrace();
 79         }finally{
 80             JdbcUtils.release(conn, st, rs);
 81         }
 82     }
 83     
 84     @Test
 85     public void update(){
 86         Connection conn = null;
 87         PreparedStatement st = null;
 88         ResultSet rs = null;
 89         try{
 90             conn = JdbcUtils.getConnection();
 91             String sql = "update users set name=?,email=? where id=?";
 92             st = conn.prepareStatement(sql);
 93             st.setString(1, "gacl");
 94             st.setString(2, "gacl@sina.com");
 95             st.setInt(3, 2);
 96             int num = st.executeUpdate();
 97             if(num>0){
 98                 System.out.println("更新成功!!");
 99             }
100         }catch (Exception e) {
101             e.printStackTrace();
102             
103         }finally{
104             JdbcUtils.release(conn, st, rs);
105         }
106     }
107     
108     @Test
109     public void find(){
110         Connection conn = null;
111         PreparedStatement st = null;
112         ResultSet rs = null;
113         try{
114             conn = JdbcUtils.getConnection();
115             String sql = "select * from users where id=?";
116             st = conn.prepareStatement(sql);
117             st.setInt(1, 1);
118             rs = st.executeQuery();
119             if(rs.next()){
120                 System.out.println(rs.getString("name"));
121             }
122         }catch (Exception e) {
123             
124         }finally{
125             JdbcUtils.release(conn, st, rs);
126         }
127     }
128 }

   以上就是使用JDBC对数据库进行CRUD的简单总结。

 

JDBC学习入门

标签:

原文地址:http://www.cnblogs.com/doudouxiaoye/p/5778110.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!