Java基础之JDBC的数据库连接与基本操作

一、JDBC概述

  • JDBC全称Java Database Connectivity,它是一个独立于特定数据库管理系统、通用的SQL数据库存取和操作的公共接口,定义了用来访问数据库的标准Java类库,使用这个类库可以以一种标准的方法、方便地访问数据库资源
  • 通俗的来说,JDBC就是让我们通过Java来连接任何提供了JDBC驱动程序的数据库系统,比如我有一个SQLServer数据和一个Mysql数据库,我可以通过Java的JDBC来完成前面学习SQL中的所有操作,而无需在命令行来分别连接它们两个,就像这样

二、JDBC操作数据库、操作表步骤

我来总结一下JDBC操作数据库与表的步骤,然后详细来介绍它们

1.注册驱动 (只做一次)

2.建立连接(Connection)

3.创建执行SQL的语句(Statement)

4.执行语句

5.处理执行结果(ResultSet)

6.释放资源

看到这里是不是很熟悉,没错,就跟我们前面学习Mysql一样,首先我来介绍一下JDBC的结构与数据库的连接

三、JDBC体系结构与JDBC API

JDBC体系结构由下面两部分组成:

  • 面向应用的API:Java API,抽象接口,供应用程序开发人员使用(连接数据库,执行SQL语句,获得结果)。
  • 面向数据库的API:Java Driver API,供开发商开发数据库驱动程序使用

JDBC API

  • JDBC API 是一系列的接口,它使得应用程序能够进行数据库联接,执行SQL语句,并且得到返回结果

四、注册与加载驱动

Driver接口

  • java.sql.Driver 接口是所有 JDBC 驱动程序需要实现的接口。这个接口是提供给数据库厂商使用的,不同数据库厂商提供不同的实现
  • 在程序中不需要直接去访问实现了 Driver 接口的类,而是由驱动程序管理器类(java.sql.DriverManager)去调用这些Driver实现
  • Oracle的驱动:oracle.jdbc.driver.OracleDriver
  • mySql的驱动: com.mysql.jdbc.Driver

加载与注册JDBC驱动

前面我们说了,JDBC就是通过一个接口和不同数据库提供了JDBC的驱动来完成数据的操作,因此,我们将驱动加载到JDBC中,加载驱动有两种方式:

方式一:加载 JDBC 驱动需调用 Class 类的静态方法 forName(),向其传递要加载的 JDBC 驱动的类名

Class.forName(“com.mysql.jdbc.Driver”);

方式二:DriverManager 类是驱动程序管理器类,负责管理驱动程序

DriverManager.registerDriver(com.mysql.jdbc.Driver);

通常不用显式调用 DriverManager 类的 registerDriver() 方法来注册驱动程序类的实例,因为 Driver 接口的驱动程序类都包含了静态代码块,在这个静态代码块中,会调用 DriverManager.registerDriver() 方法来注册自身的一个实例

五、建立连接(Connection)

  • 当我们注册并加载驱动后,就可以连接数据库了,方法和前面我们学习Mysql一样,首先需要输入账号,密码等信息
  • 在JDBC中,我们需要调用DriverManager 类的 getConnection() 方法建立到数据库的连接
  • user,password可以用“属性名=属性值”方式告诉数据库;
  • 在JDBC中连接数据库需要一个特殊的属性,JDBC URL,它用于连接我们需要操作的数据库
  • JDBC URL的标准由三部分组成,各部分间用冒号分隔。
jdbc:子协议:子名称
协议:JDBC URL中的协议总是jdbc
子协议:子协议用于标识一个数据库驱动程序
子名称:一种标识数据库的方法。子名称可以依不同的子协议而变化,用子名称的目的是为了定位数据库提供足够的信息。包含主机名(对应服务端的ip地址),端口号,数据库名

下面我来列举几个常见的JDBC URL,大家使用的时候直接复制就好

// 对于 Oracle 数据库连接,采用如下形式:
jdbc:oracle:thin:@localhost:1521:DatabaseName
// 对于 SQLServer 数据库连接,采用如下形式:
jdbc:microsoft:sqlserver//localhost:1433; DatabaseName=sid
// 对于 MYSQL 数据库连接,采用如下形式:
jdbc:mysql://localhost:3306/DatabaseName
// 插入中文的时候,这个url要写成这个
jdbc:mysql://localhost:3306/数据库名称?useUnicode=true&characterEncoding=UTF-8

小伙伴们注意一下,当我们使用Java向数据库中插入一个数据时,如果是中文,首先数据库和表的编码是utf8,其次就是我们要在URL中声明一下编码是UTF-8,不然插入数据是?,如果你们遇到这个问题,那就忽略它

好了,下面是连接数据库的示例代码,这里我操作的是Mysql数据库

package com.company;
// 导入依赖包
import org.junit.Test;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

public class Demo1 {
/*
*获取connect的三种方式
*  */
    public static void main(String[] args) {
        System.out.println("JDBC Test...");
    }

	// 使用Driver来实现数据库连接
    @Test
    public void test1() throws SQLException {
		//
        Driver driver=new com.mysql.jdbc.Driver();
        Properties p1 = new Properties();
        p1.setProperty("user", "root");
        p1.setProperty("password", "mysql123");
        Connection connect = driver.connect("jdbc:mysql://localhost:3306/myemployees", p1);
        System.out.println("connect = " + connect);

    }

	// 使用DriverManager来实现数据库连接
    @Test
    public void test2() throws SQLException {
        com.mysql.jdbc.Driver driver = new com.mysql.jdbc.Driver();
        Properties p1 = new Properties();
        p1.setProperty("user", "root");
        p1.setProperty("password", "mysql123");
        DriverManager.registerDriver(driver);
        Connection connection = DriverManager.getConnection
                ("jdbc:mysql://localhost:3306/myemployees", p1);

        System.out.println("connection = " + connection);

    }
	// 将账号密码抽出到配置文件中,并使用IO流读取配置文件的方式连接数据库
    @Test
    public void test3() throws Exception {
        Properties p = new Properties();

        FileInputStream fis = new FileInputStream("p.properties");
        p.load(fis);
        fis.close();
        Class.forName(p.getProperty("driverClass"));
        Connection connection = DriverManager.getConnection(p.getProperty("url"),
                p.getProperty("user"), p.getProperty("password"));
        System.out.println("connection = " + connection);

    }
}

properties文件内容

url=jdbc:mysql://localhost:3306/myemployees
user=root
password=mysql123
driverClass=com.mysql.jdbc.Driver

六、使用PreparedStatement

介绍完注册驱动与数据库的连接,接下来就是操作SQL了,在JDBC中,操作SQL需要使用Connection 对象的 preparedStatement() 方法获取 PreparedStatement 对象

PreparedStatement 接口是 Statement 的子接口,它表示一条预编译过的 SQL 语句

PreparedStatement 对象所代表的 SQL 语句中的参数用问号(?)来表示,调用 PreparedStatement 对象的 setXxx() 方法来设置这些参数. setXxx() 方法有两个参数,第一个参数是要设置的 SQL 语句中的参数的索引(从 1 开始),第二个是设置的 SQL 语句中的参数的值

在操作SQL前还要说明一下数据类型,我们知道SQL与Java的数据类型命名是不一样的,所以我们在编码时要注意

java类型 SQL类型
boolean BIT
byte TINYINT
short SMALLINT
int INTEGER
long BIGINT
String CHAR,VARCHAR,LONGVARCHAR
byte array BINARY , VAR BINARY
java.sql.Date DATE
java.sql.Time TIME
java.sql.Timestamp TIMESTAMP

使用PreparedStatementSQL的操作步骤

1.调用连接对象的prepareStatement方法,创建PreparedStatement对象

2.完成预编译的SQL语句

3.对SQL语句中的占位符进行赋值

4.提交SQL语句

5.释放资源

接下来就是操作SQL增删改查的示例代码(为了方便操作,我将数据库连接抽出到了JDBCUtils类中)

// 使用PreparedStatement来完成数据的增删改查操作
package com.company.jdbc;

import org.junit.Test;

import java.io.FileInputStream;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

/*
 对数据库进行增,删,改,查的操作
 */
public class CRUDDemo {

    /*
        添加一条数据

        CREATE TABLE student(
        sid INT,
        sname VARCHAR(20),
        sage INT
        )
     */
    @Test
    public void test() throws SQLException {
        //1.获取数据库连接对象
        Connection connection = JDBCUtils.getConnection();
        //2.预编译
        // ? : 占位符(只能是设置数据的地方可以写成占位符)
        String sql = "insert into student(sid,sname,sage) values(?,?,?)";
        PreparedStatement ps = connection.prepareStatement(sql);
        //3.给占位符赋值
        /*
        setInt(int parameterIndex, int x)
        parameterIndex : 参数索引(第几个占位符)
        x : 数据
         */
        ps.setInt(1,100);
        //数据设置成中文可不可以取决于表的编码集
        ps.setString(2,"longge");
        ps.setInt(3,20);
        //4.执行sql
        //返回值 : 有几条数据受到影响
        int result = ps.executeUpdate();//增,删,改的语句使用该方法
        System.out.println("有"+result+"条数据受到影响");
        //5.关资源
        JDBCUtils.close(ps,connection);
    }

    /*
        改
     */
    @Test
    public void test2() throws SQLException {
        //1.获取数据库连接对象
        Connection connection = JDBCUtils.getConnection();
        //2.预编译
        String sql = "update student set sid=? where sid=?";
        PreparedStatement ps = connection.prepareStatement(sql);
        //3.给占位符赋值
        ps.setInt(1,10);
        ps.setInt(2,100);
        //4.执行sql语句
        int result = ps.executeUpdate();
        System.out.println("有"+result+"条数据受到影响");
        //5.关闭资源
        JDBCUtils.close(ps,connection);
    }

    /*
        删除数据
     */
    @Test
    public void test3() throws SQLException {
        //1.获取数据库连接对象
        Connection connection = JDBCUtils.getConnection();
        //2.预编译
        String sql = "delete from student where sid=?";
        PreparedStatement ps = connection.prepareStatement(sql);
        //3.给占位符赋值
        ps.setInt(1,10);
        //4.执行sql语句
        int i = ps.executeUpdate();
        System.out.println("有"+i+"条数据受到影响");
        //5.关闭资源
        JDBCUtils.close(ps,connection);
    }

    /*
        查询数据
     */
    @Test
    public void test4() throws Exception {
        List<Student> students = getStudent();
        for (Student s : students) {
            System.out.println(s);
        }

    }

    public List<Student> getStudent() throws Exception {
        //1.获取数据库连接对象
        Connection connection = JDBCUtils.getConnection();
        //2.预编译
        PreparedStatement ps = connection.prepareStatement("select sid,sname,sage from student");
        //3.执行sql语句
        ResultSet resultSet = ps.executeQuery();//查询语必须执行此方法

        List<Student> list =  new ArrayList<>();
        //4.遍历ResultSet
        while(resultSet.next()){//是否有数据
            /*
                getInt(String columnLabel) :根据字段名获取对应的数据
                getInt(int columnIndex) : 根据列的索引获取对应的数据
             */
            int sid = resultSet.getInt("sid");
            String sname = resultSet.getString("sname");
            int sage = resultSet.getInt("sage");

            //System.out.println(sid + " " + sname + " " + sage);
            list.add(new Student(sid,sname,sage));
        }
        //5.关闭资源
        JDBCUtils.close(ps,connection,resultSet);

        return list;
    }

}

JDBCUtils连接数据库的工具类

//JDBCUtils类,专门实现数据库的连接与资源释放操作
package com.company.jdbc;

import java.io.FileInputStream;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;

    static{
        FileInputStream fis = null;
        try {
            //1.获取数据库连接对象
            //通过Properties读取内容
            //1.创建Properties对象
            Properties p = new Properties();
            //2.加载流
            fis = new FileInputStream("jdbc.properties");
            p.load(fis);
            driverClass = p.getProperty("driverClass");
            url = p.getProperty("url");
            username = p.getProperty("username");
            password = p.getProperty("password");
        }catch (Exception e){
            //终止程序的运行
            e.printStackTrace();
            //将编译时异常转换成运行时异常
            throw new RuntimeException("xxxxxxxx");
        }finally {
            if (fis != null){
                //3.关资源
                try {
                    fis.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    /*
        获取连接对象
     */
    public static Connection getConnection(){
        try {
            Class.forName(driverClass);
            //获取数据库连接对象
            Connection connection = DriverManager.getConnection(url, username, password);
            return connection;
        }catch (Exception e){
            e.printStackTrace();
            throw new RuntimeException("获取连接失败");
        }
    }

    /*
        关闭资源
     */
    public static void close(PreparedStatement ps, Connection connection) {
        if (ps != null){
            try {
                ps.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }

        if (connection != null){
            try {
                connection.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }

    public static void close(PreparedStatement ps, Connection connection, ResultSet resultSet) {
        close(ps,connection);
        if (resultSet != null){
            try {
                resultSet.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }
}

七、关于ResultSet的说明

在前面对数据的增删改查操作中,查询操作比较复杂一些,因为我们要接收数据库返回的结果,因此我们要了解一下ResultSet 接口,它由数据库厂商实现

查询需要调用Prepared Statement 的 executeQuery() 方法,查询结果是一个 ResultSet 对象

ResultSet 对象维护了一个指向当前数据行的游标,初始的时候,游标在第一行之前,可以通过 ResultSet 对象的 next() 方法移动到下一行,具体方法可以自定百度

ResultSet:代表结果集,其封装了使用 JDBC 进行查询的结果. 调用 PreparedStatement 对象的 executeQuery() 可以得到结果集.ResultSet 返回的实际上就是一张数据表. 有一个指针指向数据表的第一条记录的前面

八、总结

本章主要介绍了JDBC以及JDBC如何连接数据库,实现数据的增删改查操作,下一章是JDBC的扩展知识—>我们自己实现的那个连接数据库的工具类毕竟不是那么严谨,下一章就是介绍一个框架,以后连接数据库就不用这么麻烦了.

到此这篇关于Java基础之JDBC的数据库连接与基本操作的文章就介绍到这了,更多相关JDBC的数据库连接与基本操作内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Java中JDBC连接数据库详解

    一.概念 1. 为了能让程序操作数据库,对数据库中的表进行操作,每一种数据库都会提供一套连接和操作该数据库的驱动,而且每种数据库的驱动都各不相同,例如mysql数据库使用mysql驱动,oracle数据库使用oracle驱动,这样假如我们编写的程序哪一天想要换数据库,那样就会很不方便,因为所有连接数据库的代码都要从新编写.SUN公司为了简化.统一对数据库的操作,定义了一套java操作数据库的标准或者规范,这个规范就是JDBC. 2.JDBC全称为:Java Data Base Connectiv

  • java使用jdbc连接数据库简单实例

    本文为大家分享了java使用jdbc连接数据库的具体代码,供大家参考,具体内容如下 package com.tr.jdbc; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import org.apache.commons.dbcp2.BasicDataSource; public class CollectionFac

  • Java编程中使用JDBC API连接数据库和创建程序的方法

    JDBC连接数据库 涉及到建立一个JDBC连接的编程是相当简单的.下面是这些简单的四个步骤: 导入JDBC包: 添加import语句到Java程序导入所需的类在Java代码中. 注册JDBC驱动程序:这一步会导致JVM加载所需的驱动程序实现到内存中,因此它可以实现JDBC请求. 数据库URL制定:这是创建格式正确的地址指向到要连接的数据库. 创建连接对象:最后,代码调用DriverManager对象的getConnection()方法来建立实际的数据库连接. 导入JDBC包: import 语句

  • Java 如何使用JDBC连接数据库

    一.使用JDBC连接数据库 1.使用JDBC-ODBC桥驱动程序连接数据库 基本步骤: (1)加载并注册数据库驱动 (2)通过DriverManager获取数据库连接 (3)通过Connection对象获取Statement对象 (4)使用Statement接口执行SQL语句 (5)操作ResultSet结果集 (6)关闭连接,释放资源 2.下面进行代码演示 1.注册数据库驱动程序的语法格式如下: DriverManager.registerDriver(Driver driver) 或者 Cl

  • java 中JDBC连接数据库代码和步骤详解及实例代码

    java 中JDBC连接数据库代码和步骤详解 JDBC连接数据库 •创建一个以JDBC连接数据库的程序,包含7个步骤:  1.加载JDBC驱动程序:  在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String  className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(Class

  • java使用JDBC连接数据库的五种方式(IDEA版)

    JDBC是java访问数据库的基础,其余的mybatis和JDO 以及Hibernate 都是把jdbc封装起来,因此了解JDBC连接数据库的原理十分重要!! 准备工作 1. mysql的jar包 导入到lib目录下 2.把导入的jar包添加到项目中 点击jar包   选择 3.创建一个TestConnection类 五种方式如下: /** * @author * @date 2019 **/ import org.junit.Test; import java.io.InputStream;

  • java开发中基于JDBC连接数据库实例总结

    本文实例讲述了java开发中基于JDBC连接数据库的方法.分享给大家供大家参考,具体如下: 创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String  className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }c

  • Spring Boot JDBC 连接数据库示例

    文本将对在spring Boot构建的Web应用中,基于MySQL数据库的几种数据库连接方式进行介绍. 包括JDBC.JPA.MyBatis.多数据源和事务. JDBC 连接数据库 1.属性配置文件(application.properties) spring.datasource.url=jdbc:mysql://localhost:3306/test spring.datasource.username=root spring.datasource.password=123456 sprin

  • Java实现JDBC连接数据库简单案例

    一.准备好数据库 例如,MS SQL Server2008环境下,创建school数据库,内含一个表student(sid,sname,ssex,sage),并添加若干行数据. 二.配置数据库驱动文件 1.准备好(下载)sqlserver2008.jar文件: 2.拷贝下载的jar文件到工程中: 在java工程中创建lib目录,拷贝数据库驱动jar文件到该目录 3.添加并在Eclipse的Java工程中配置 (右击工程,选择Bulid path–>config Build Path–>addJ

  • Java连接数据库JDBC技术之prepareStatement的详细介绍

    一.prepareStatement 的用法和解释 1.PreparedStatement是预编译的,对于批量处理可以大大提高效率. 也叫JDBC存储过程 2.使用 Statement 对象.在对数据库只执行一次性存取的时侯,用 Statement 对象进行处理.PreparedStatement 对象的开销比Statement大,对于一次性操作并不会带来额外的好处. 3.statement每次执行sql语句,相关数据库都要执行sql语句的编译,preparedstatement是预编译得, p

  • Spring的连接数据库以及JDBC模板(实例讲解)

    前言 今天介绍的是关于Spring的数据库连接以及Jdbc模板的相关API方法,虽然在学习了hibernate之后,会知道实现数据库连接一般都是使用hibernate等持久化框架来实现的.但是,很多时候一些涉及到事务的东西使用这些框架并不能够实现,所以我们还需要结合spring来实现相关的需要. 一.创建工程.导包 要想使用Spring的jdbc模板前,还需要导入相关的jar包: 二.进行相关的bean的创建以及工具类的编写 2.1在数据库中创建了两张表,使用spring的jdbcTemplat

  • Java基于JDBC连接数据库及显示数据操作示例

    本文实例讲述了Java基于JDBC连接数据库及显示数据操作.分享给大家供大家参考,具体如下: 1. 导入jdbc包 java要连接MySQL数据库需要用到JDBC工具(mysql-connector-java-5.1.39-bin.jar),这是一个jar包,不同的数据库对应不同的jar包,这里用的是MySQL数据库jar包,导入很简单,鼠标对项目右击 - Build Path - Configure Build Path - 右侧选Libraries - Add External JARs,选

  • spring通过jdbc连接数据库

    本文实例为大家分享了spring通过jdbc连接数据库的具体代码,供大家参考,具体内容如下 首先看下整个工程的架构目录: 需要的jar包: 一.建表 create table student( id int primary key auto_increment, name varchar(32), age int, phone varchar(32) ); 二.新建与数据库对应JavaBean package com.etoak.bean; public class Student { /**

  • JDBC利用C3P0数据库连接池连接数据库

    JDBC之C3P0数据库连接池,供大家参考,具体内容如下 1 首先在src中创建c3p0-config.xml 配置文件,文件中内容如下(首先下载C3P0.jar工具包 并放入项目环境变量中) <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE xml> <c3p0-config> <!--下面四个是数据库连接必须需要的东西 --> <named-config nam

随机推荐