jdbc入门

一、JDBC简介

SUN公司为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范,称之为JDBC。

 

 

  • JDBC全称为:Java Data Base Connectivity(java数据库连接),它主要由接口组成。
  • 组成JDBC的2个包:

java.sql

javax.sql

  • 开发JDBC应用需要以上2个包的支持外,还需要导入相应JDBC的数据库实现(即数据库驱动)。

 

1、第一个jdbc程序

 1 package com.demo;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 
 7 import com.mysql.jdbc.Statement;
 8 
 9 public class demo1 {
10     public static void main(String[] args) throws SQLException {
11         String url = "jdbc:mysql://localhost:3306/day14";
12         String username = "root";
13         String password = "root";
14         //1、注册驱动,使用此方式驱动会注册两次
15         DriverManager.registerDriver(new com.mysql.jdbc.Driver() );
16         //2、获取连接
17         Connection con = DriverManager.getConnection(url, username, password);
18         //3、获取向数据库发sql语句的Statement对象
19         Statement statement = (Statement) con.createStatement();
20         //4、向数据库发送sql语句,获取返回的结果集
21         ResultSet result = statement.executeQuery("select * from users");
22         //4、处理结果集
23         while (result.next()) {
24             System.out.println("id="+result.getObject("id"));
25             System.out.println("name="+result.getObject("name"));
26             System.out.println("password="+result.getObject("password"));
27             System.out.println("email="+result.getObject("email"));
28             System.out.println("birthday"+result.getObject("birthday"));
29         }
30         
31         //5、关闭连接,释放资源
32         result.close();
33         statement.close();
34         con.close();
35     }
36 }

 

 

二、JDBC详解

1、DriverManager类

Jdbc程序中的DriverManager用于加载驱动,并创建与数据库的链接,这个API的常用方法:DriverManager.registerDriver(new Driver())DriverManager.getConnection(url, user, password)

 

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

我们来查看Dirver类的源代码:

 

 1 package com.mysql.jdbc;    
 2     
 3 import java.sql.SQLException;    
 4 public class Driver extends NonRegisteringDriver implements java.sql.Driver {    
 5         
 6        //执行这个静态代码块    
 7     static {    
 8         try {//注册mysql实现的驱动类    
 9             java.sql.DriverManager.registerDriver(new Driver());    
10         } catch (SQLException E) {    
11             throw new RuntimeException("Can't register driver!");    
12         }    
13     }    
14     
15     public Driver() throws SQLException {    
16         // Required for Class.forName().newInstance()    
17     }    
18 }    

 

 

 

由此可见用registerDriver()方式会导致驱动注册两次。

 

推荐方法:Class.forName(“com.mysql.jdbc.Driver”),采用此种方式不会导致驱动对象在内存中重复出现,并且采用此种方式,程序仅仅只需要一个字符串,不需要依赖具体的驱动,使程序的灵活性更高。同时这种方法是利用反射机制加载驱动的。

 1 package com.demo;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 
 7 import com.mysql.jdbc.Statement;
 8 
 9 public class demo2 {
10     public static void main(String[] args) throws SQLException, ClassNotFoundException {
11         String url = "jdbc:mysql://localhost:3306/day14";
12         String username = "root";
13         String password = "root";
14         //1、注册驱动
15          Class.forName("com.mysql.jdbc.Driver");
16         //2、获取连接
17         Connection con = DriverManager.getConnection(url, username, password);
18         //3、获取向数据库发sql语句的Statement对象
19         Statement statement = (Statement) con.createStatement();
20         //4、向数据库发送sql语句,获取返回的结果集
21         ResultSet result = statement.executeQuery("select * from users");
22         //4、处理结果集
23         while (result.next()) {
24             System.out.println("id="+result.getObject("id"));
25             System.out.println("name="+result.getObject("name"));
26             System.out.println("password="+result.getObject("password"));
27             System.out.println("email="+result.getObject("email"));
28             System.out.println("birthday"+result.getObject("birthday"));
29         }
30         
31         //5、关闭连接,释放资源
32         result.close();
33         statement.close();
34         con.close();
35     }
36 }

 

 2、数据库URL

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

  

 

 

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

Oracle写法:jdbc:oracle:thin:@localhost:1521:sid

SqlServer—dbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid

MySql—jdbc:mysql://localhost:3306/sid

Mysql的url地址的简写形式: jdbc:mysql:///sid

常用属性:useUnicode=true&characterEncoding=UTF-8

 

3、Connection详解

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

createStatement():创建向数据库发送sql的statement对象。

prepareStatement(sql) :创建向数据库发送预编译sql的PrepareSatement对象。

prepareCall(sql):创建执行存储过程的callableStatement对象。

setAutoCommit(boolean autoCommit):设置事务是否自动提交。

commit() :在链接上提交事务。

rollback() :在此链接上回滚事务。

 

4、Statement详解

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

executeQuery(String sql) :用于向数据发送查询语句。

executeUpdate(String sql):用于向数据库发送insert、update或delete语句

execute(String sql):用于向数据库发送任意sql语句

addBatch(String sql) :把多条sql语句放到一个批处理中。

executeBatch():向数据库发送一批sql语句执行。 

 

5、ResultSet详解

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

ResultSet既然用于封装执行结果的,所以该对象提供的都是用于获取数据的get方法:

获取任意类型的数据

getObject(int index)

getObject(string columnName)

获取指定类型的数据,例如:

etString(int index)

getString(String columnName)

 

 

 

 

ResultSet还提供了对结果集进行滚动的方法:

 

next():移动到下一行

Previous():移动到前一行

absolute(int row):移动到指定行

beforeFirst():移动resultSet的最前面。

afterLast() :移动到resultSet的最后面。

 

 

常用数据类型转换表:

 

 

 把数据封装到javabean

 1 package com.demo;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 
 7 import com.domain.User;
 8 import com.mysql.jdbc.Statement;
 9 
10 public class demo3 {
11     public static void main(String[] args) throws SQLException, ClassNotFoundException {
12         String url = "jdbc:mysql://localhost:3306/day14";
13         String username = "root";
14         String password = "root";
15         //1、注册驱动
16          Class.forName("com.mysql.jdbc.Driver");
17         //2、获取连接
18         Connection con = DriverManager.getConnection(url, username, password);
19         //3、获取向数据库发sql语句的Statement对象
20         Statement statement = (Statement) con.createStatement();
21         //4、向数据库发送sql语句,获取返回的结果集
22         ResultSet result = statement.executeQuery("select * from users");
23         //4、处理结果集
24         while (result.next()) {
25             User user = new User();
26             user.setId(result.getInt("id"));
27             user.setName(result.getString("name"));
28             user.setPassword(result.getString("password"));
29             user.setDate(result.getDate("birthday"));
30             System.out.println(user.getId()+","+user.getName()+","+user.getEmail()+","+user.getPassword()+","+user.getDate());
31         }
32         
33         //5、关闭连接,释放资源
34         result.close();
35         statement.close();
36         con.close();
37     }
38 }

 

 

6、释放资源

Jdbc程序运行完后,切记要释放程序在运行过程中,创建的那些与数据库进行交互的对象,这些对象通常是ResultSet, Statement和Connection对象。

特别是Connection对象,它是非常稀有的资源,用完后必须马上释放,如果Connection不能及时、正确的关闭,极易导致系统宕机。Connection的使用原则是尽量晚创建,尽量早的释放。

为确保资源释放代码能运行,资源释放代码也一定要放在finally语句中。

 

严谨的释放资源代码:把释放连接的语句放在finally一定会被执行

 1 package com.demo;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 
 7 import javax.naming.spi.DirStateFactory.Result;
 8 
 9 import com.domain.User;
10 import com.mysql.jdbc.Statement;
11 
12 public class demo4 {
13     public static void main(String[] args) throws SQLException, ClassNotFoundException {
14         String url = "jdbc:mysql://localhost:3306/day14";
15         String username = "root";
16         String password = "root";
17         Connection con = null;
18         Statement statement = null;
19         ResultSet result = null;
20         try {
21             //1、注册驱动
22              Class.forName("com.mysql.jdbc.Driver");
23             //2、获取连接
24              con = DriverManager.getConnection(url, username, password);
25             //3、获取向数据库发sql语句的Statement对象
26              statement = (Statement) con.createStatement();
27             //4、向数据库发送sql语句,获取返回的结果集
28              result = statement.executeQuery("select * from users");
29             //4、处理结果集
30             while (result.next()) {
31                 User user = new User();
32                 user.setId(result.getInt("id"));
33                 user.setName(result.getString("name"));
34                 user.setPassword(result.getString("password"));
35                 user.setDate(result.getDate("birthday"));
36             }
37         }finally{//5、释放资源
38             if(result!=null){
39                 try {
40                     result.close();
41                 } catch (Exception e) {
42                     e.printStackTrace();
43                 }
44                 result = null;
45             }
46             
47             if(statement!=null){
48                 try {
49                     statement.close();
50                 } catch (Exception e) {
51                     e.printStackTrace();
52                 }
53                 statement = null;
54             }
55             if(con!=null){
56                 try {
57                     con.close();
58                 } catch (Exception e) {
59                     e.printStackTrace();
60                 }
61             }
62         }
63     }
64 }

 

 7、用jdbc完成crud操作

工具类:完成驱动注册和获取连接

 1 package com.util;
 2 
 3 
 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 DButils {
12     //保存配置文件信息
13         private static Properties config = new Properties();
14         static{
15             try {//装载配置文件的信息,通过类的加载器进行加载
16                 
17                 config.load(DButils.class.getClassLoader().getResourceAsStream("db.properties"));
18                 //注册驱动
19                 Class.forName(config.getProperty("driver"));
20             } catch (Exception e) {
21                 throw new ExceptionInInitializerError(e);
22             }
23         }
24         
25         public static Connection getConnection() throws SQLException{
26             //获取连接
27             return DriverManager.getConnection(config.getProperty("url"),config.getProperty("username"),config.getProperty("password"));
28         }
29         
30         public static void release(Connection con,Statement st,ResultSet result){
31             //释放资源
32             if(result!=null){
33                 try {
34                     result.close();
35                 } catch (Exception e) {
36                     e.printStackTrace();
37                 }
38                 result = null;
39             }
40             
41             if(st!=null){
42                 try {
43                     st.close();
44                 } catch (Exception e) {
45                     e.printStackTrace();
46                 }
47                 st = null;
48             }
49             
50             if(con!=null){
51                 try {
52                     con.close();
53                 } catch (Exception e) {
54                     e.printStackTrace();
55                 }
56                 
57             }
58         }
59 }

 

 

 

 crud操作:

 

package com.demo;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import org.junit.Test;

import com.domain.User;
import com.util.DButils;

public class demo {
    
    
    //插入数据
    @Test
    public void insert() throws SQLException{
        //连接引用
        Connection con = null;
        Statement st = null;
        ResultSet result = null;
        
        try {
            //sql语句
            String sql = "insert into users(id,name,password,email) values(5,'eee','123','ee@sina.com')";
            
            //获取连接
            con = DButils.getConnection();
            //获取发送sql语句的statement
            st = con.createStatement();
            int num = st.executeUpdate(sql);
            //num如果大于小
            if(num>0){
                System.out.println("插入成功");
            }
            
        } finally{
            DButils.release(con, st, result);
        }
        
    }
    
    @Test
    //更新数据
    public void update() throws SQLException{
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            String sql = "update users set password='320' where id=5";
            con = DButils.getConnection();
            st = con.createStatement();
            int num = st.executeUpdate(sql);
            if(num>0){
                System.out.println("更新成功");
            }
        }finally{
            DButils.release(con, st, rs);
        }
    }
    
    
    
    //删除数据
    @Test
    public void delete() throws SQLException{
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        try{
            String sql = "delete from users where id=5";
            con = DButils.getConnection();
            st = con.createStatement();
            int num = st.executeUpdate(sql);
            if(num>0){
                System.out.println("删除成功");
            }
            
        }finally{
            DButils.release(con, st, rs);
        }
    }
    //查找数据
    //删除数据
        @Test
        public void find() throws SQLException{
            Connection con = null;
            Statement st = null;
            ResultSet rs = null;
            try{
                String sql = "select id,name,password,email,birthday from users where name='eee'";
                con = DButils.getConnection();
                st = con.createStatement();
                rs = st.executeQuery(sql);
                if(rs.next()){
                    User user = new User(); 
                    user.setId(rs.getInt("id"));
                    user.setName(rs.getString("name"));
                    user.setEmail(rs.getString("email"));
                    user.setPassword(rs.getString("password"));
                    user.setDate(rs.getDate("birthday"));
                    System.out.println(user.getEmail());
                    
                }
                
            }finally{
                DButils.release(con, st, rs);
            }
        }
     
}

 

 

 

 

 配置文件:

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

 

 如果想切换数据库直接修改配置文件即可。

 

 

 

 

 

 

 

 

 

 

原文地址:https://www.cnblogs.com/niuchuangfeng/p/9147613.html