java之JDBC

分类：JDBC作者：编程之家用户

一.JDBC基础

1.1数据库驱动

我们安装好数据库后，我们的应用程序是不能直接使用数据库的，需要通过相应的数据库驱动程序，然后通过驱动程序才可以和数据库沟通，即JAVA应用程序--ORACLE/MYSQL/SQL SERVER驱动--ORACLE/MYSQL/SQL SERVER数据库。

1.2JDBC介绍

Oracle-Sun公司为了简化和统一对数据库的操作，定义了一套java操作数据库的规范（接口），称为JDBC，然后各个数据库厂商按照这个规范（接口）去实现，然后，广大的开发人员只需要学习JDBC规范（接口），然后通过JDBC加载相应的驱动程序，就可以完成操作数据库的工作，即：JAVA应用程序--JDBC--ORACLE/MYSQL/SQL SERVER驱动--ORACLE/MYSQL/SQL SERVER数据库。

在开发JDBC应用程序时需要用到两个包：java.sql和javax.sql，同时还需要导入相应的JDBC数据库驱动。

1.3编写JDBC程序

package com.boxiaoyuan.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcFirstDemo {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/jdbcStudy";
        String username = "root";
        String password = "aaaaaa";
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            //1.加载驱动
            Class.forName("com.mysql.jdbc.Driver");//推荐使用这种方式来加载驱动
            //2.获取与数据库的连接
            conn = DriverManager.getConnection(url, username, password);    
            //3.获取用于向数据库发送sql语句的statement
            stmt = conn.createStatement();
            String sql = "select * from users";
            //4.向数据库发送sql，并获取结果集resultSet
            rs = stmt.executeQuery(sql);
            //5.获取结果集中的数据
            while (rs.next()) {
                System.out.println("name:" + rs.getObject("name"));
                
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(rs != null) {
                try {
                    //6.关闭连接，释放资源
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(stmt != null) {
                try {
                    //6.关闭连接，释放资源
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    //6.关闭连接，释放资源
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

1.3.1DriverManager类

JDBC程序中的DriverManager类用于加载驱动，并且创建与数据库的连接，这个API的常用方法为：DriverManager.getConnection(url, user, password)。

在实际的开发过程中，加载驱动推荐的使用方式是Class.forName("com.mysql.jdbc.Driver")；因为此方法不会导致驱动在内存中重复出现，灵活性很高。

1.3.2数据库URL

URL用于标识数据库的位置，通过URL可以让JDBC知道需要连接哪个数据库。

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

# sql server：jdbc:sqlserver://10.21.191.201:1433;DatabaseName=g1
# postgresql
jdbc:postgresql://10.21.191.201:5432/g1
# oracle
jdbc:oracle:thin:@//10.21.191.201:1521/g1
# mysql
jdbc:mysql://localhost:3306/jdbcStudy

 1.3.3Connection类

JDBC程序中的Connection标识数据库的连接，Connection是数据库编程中最重要的一个对象，客户端与数据库服务器的交互都是通过Connection对象完成的，这个对象的常用方法有：

1 createStatement()    创建一个静态sql语句对象
2 prepareStatement(String sql)  创建预编译的sql语句对象
3 prepareCall(String sql)   创建存储过程的sql语句对象

1.3.4Statement类

JDBC程序中的Statement对象用于向数据库发送SQL语句，这个对象的常用方法有：

1 executeUpdate(String sql)  执行更新操作的sql语句，create/alter/drop/insert/update/delete）     
2 executeQuery(String sql)  执行查询操作的sql语句(select)

1.3.5ResultSet类

JDBC程序中的ResultSet用于标识SQL语句的执行结果，ResultSet对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用.next()方法后，可以使游标指向具体的数据行，然后再调用方法获取改行的数据。

获取任意类型的数据：

1 getObject(int index)
2 getObject(String columnName)

获取指定类型的数据：

1 getString(int index)
2 getString(String columnName)

另外，ResultSet还提供了对结果集进行滚动的方法：

1 next()：移动到下一行
2 Previous()：移动到前一行
3 absolute(int row)：移动到指定行
4 beforeFirst()：移动到ResultSet的最前面
5 afterLast()：移动到Result的最后面

1.3.6释放资源

JDBC程序运行后，一定要释放程序运行中创建的与数据库进行交互的对象，这些对象通常为ResultSet，Statement，Connection，特别是Connection，如果该对象用完之后不能及时释放，很容易导致宕机的发生。为了确保资源释放代码能够运行，资源释放代码一定要放在finally语句中。

 二.使用JDBC对数据库进行增删改查

JDBC中的Statement对象用于向数据库发送SQL语句，如果想要完成对数据库的增删改查，只需要通过这个对象发送增删改查即可。其中该对象的executeUpdate方法，用于向数据库发送增，删，改语句，该方法执行完之后，会返回一个整数表示数据库中多少行数据发生了变化；该对象的executeQuery方法，用于向数据库中发送查询语句，该方法返回ResultSet对象，表示查询结果。

2.1准备

首先在src目录下新增加一个配置文件，db.properties，然后在里面维护Mysql数据库的连接信息：

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy
username=root
password=aaaaaa

2.2编写JdbcUtils工具类

编写JdbcUtils工具类，用来连接数据库，获取数据库连接释放数据库连接：

package com.boxiaoyuan.www;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class JdbcUtils {
    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;
    static {        
        try {
            InputStream inStream = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties prop = new Properties();
            prop.load(inStream);
            //获取连接数据库的url地址
            url = prop.getProperty("url");
            //获取数据库连接驱动
            driver = prop.getProperty("driver");
            //获取数据库连接用户名
            username = prop.getProperty("username");
            //获取数据库连接密码
            password = prop.getProperty("password");
            //加载数据库驱动
            Class.forName(driver);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }
    
    public static void release(Connection conn, Statement stmt, ResultSet rs) {
        if(rs != null) {
            try {
                //关闭结果集对象ResultSet
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                rs = null;
            }    
        }
        if(stmt != null) {
            try {
                //关闭执行SQL的对象Statement
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                stmt = null;
            }
        }
        if(conn != null) {
            try {
                //关闭数据库连接对象Connection
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                conn = null;
            }
        }
    }
}

2.3使用Statement对象增删改查

package com.boxiaoyuan.www;

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

import org.junit.jupiter.api.Test;

class Demo01 {
    @Test
    void insert() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "insert into users(id,name,password,email,birthday) values(12,'boxiaoyuan', '111111', 'test@qq.com', '1990-01-01')";
            int num = stmt.executeUpdate(sql);
            if(num>0) {
                System.out.println("插入成功");
            }
            
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }
    }
    @Test
    void delete() {
        Connection conn  = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "delete from users where id='12'";
            int num = stmt.executeUpdate(sql);
            if(num>0) {
                System.out.println("删除成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }    
    }
    @Test
    void update() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "update users set password='222222' where id='12'";
            int num = stmt.executeUpdate(sql);
            if(num>0) {
                System.out.println("修改成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }
    }
    @Test
    void query() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "select * from users";
            rs = stmt.executeQuery(sql);
            while(rs.next()) {
                System.out.println(rs.getObject("name")+"----"+rs.getObject("password"));
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }    
    }
}

3.PreparedStatement对象介绍

PreparedStatement是Statement的子类，它的实例可以通过Connection.preparedStatement方法获得，与Statement对象比较，PreparedStatement可以避免SQL注入。

Statement会使数据库频繁的编译SQL，可能会造成数据库缓冲器溢出，但是PreparedStatement可以对SQL进行预编译，从而提高了数据库的执行效率。

3.1使用PreparedStatement对象增删改查

package com.boxiaoyuan.www;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.jupiter.api.Test;


class Demo01 {
    @Test
    void insert() {
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1, 13);
            stmt.setString(2, "bodayuan");
            stmt.setString(3, "aaaaaa");
            stmt.setString(4, "aa@sina.com");
            stmt.setDate(5, new Date(new java.util.Date().getTime()));
            int num = stmt.executeUpdate();
            if(num>0) {
                System.out.println("插入成功");
            }
            
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }
    }
    @Test
    void delete() {
        Connection conn  = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            String sql = "delete from users where id=?";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1, 13);
            int num = stmt.executeUpdate();
            if(num>0) {
                System.out.println("删除成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }    
    }
    @Test
    void update() {
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            String sql = "update users set password=? where id=?";
            stmt = conn.prepareStatement(sql);
            stmt.setString(1, "bbbbbb");
            stmt.setInt(2, 13);
            int num = stmt.executeUpdate();
            if(num>0) {
                System.out.println("修改成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }
    }
    @Test
    void query() {
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();
            String sql = "select * from users where id=?";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1, 13);
            rs = stmt.executeQuery();
            while(rs.next()) {
                System.out.println(rs.getObject("name")+"----"+rs.getObject("password"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils.release(conn, stmt, rs);
        }    
    }
}

 

原文地址：https://www.cnblogs.com/zhuzhaoli/p/10747535.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

讲解JDBC
连接数据库的方式：第一种方式：ODBC：开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分，是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口，便于语言和数据库通信以及语言对数据库的各种操作。第二种方式：JDBC（本章重点）在Java中，
Jmeter 数据库请求
JDBCRequest 使用VariableNamesmysql：数据库连接池对象variousname：设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#：代表行数a_1：第1行、第1列b_2：第2行、第2列
抽取基本JDBC中的基本操作与数据连接池
 1.JDBCDBC(JavaDataBaseConnectivity)：Java数据库连接技术：具体讲就是通过Java连接广泛的数据库，并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型：增删改基本操作：（1）获取连接：Connectionconnection=
JDBC操作流程
1.需要jar包的支持：java.sqljavax.sqlmysql-conneter-java...连接驱动（必须要导入）<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
Activiti可视化流程管理器
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理，工作流，服务协作等领域的一个开源，灵活的，易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流，我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件，包含有一系列
0811JDBC随笔
1.JDBC体系系统一组规范：接口JDBC接口（API）包括两个层次：面向应用的API：JavaAPI，抽象接口，供应用开发人员使用（连接数据库，执行SQL语句，获得结果）面向数据库的API：JavaDriverAPI，供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口，java程序员只需要面向这套接
JDBC的基本概念
原文链接JDBC一般指Java数据库连接（JavaDatabaseConnectivity）api应用程序接口（API）：可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口（SPI）：需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
Shardingsphere-ShardingSphere-JDBC-Spring Boot配置-分片规则
spring.shardingsphere.datasource.names=#省略数据源配置，请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表，分隔符为点，多个数据节点用逗号分隔，支持内联表达式。Absent表示仅对数据库进行分片
20220814 idea_springboot_启动 Cannot load driver class: com.mysql.cj.jdbc.Driver
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先，去查看项目中MySQL的版本如果找不到，说明可能还没有jdbc驱动，需要配置或者引入       （1）如果是直接引用的jar包，就去lib文件夹中查看，后缀是版
JDBC
JDBC一、JDBC概述什么是JDBC？JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码，真正执行的是各个数据库的实现类（驱动）。全称：（JavaDataBaseConnectivity）Java数据库连接。JDBC的好处面向接口编
从关系型数据库中创建DataFrame
说明：/*需要引入依赖<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.18</version></dependency>*/代码：objec
通过jmeter连接人大金仓数据库
1.概要在“配置元件”中添加“JDBCConnectionConfiguration”。配置如下图： 2.重点：配置人大金仓数据库连接下面着重介绍人大金仓数据库连接配置：DatabaseURL输入：jdbc:kingbase8://192.132.180.101:54321/hj_yc   （备注：应输入 jdbc:kingbase8://IP:
2022-8-18第一组孙乃宇JDBC
JDBC概念：JavaDataBaseconnectivityJava数据库连接，Java语言操作数据库JDBc本质∶其实是官方(sun公司)定义的一套操作所有关系型数据库的规则，即接口。各个数据库商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口(JDBC）编程,真正执行的代码是驱动jar包中的实现类
mybatis核心配置文件
Mybatis核心配置文件习惯上命名mybatis-config.xml，整合Spring之后，整个配置文件可以省略核心配置文件主要用于配置连接数据库的环境以及MyBatis的全局配置信息标签顺序顺序出错会报错propertiessettingstypeAliasestypeHandlersobjectFactoryobjectWrapperFa
2022-8-18 第六组 JDBC
JDBC1.概念：JavaDataBaseConnectivityJava数据库连接，Java语言操作数据库JDBC本质：其实是官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类。
JDBC出现The server time zone value&#039;Öйú±ê׼ʱ¼ä&#039; is unrec问题
  1.出现这个问题的原因 ：在安装mysql的时候时区设置的不正确，mysql默认的是美国的时区，而我们中国大陆要比他们迟8小时，采用+8:00格式使用的数据库是MySQL，没有指定MySQL驱动版本的情况下它自动依赖的驱动是8.0.12很高的版本，这是由于数据库和系统时区差异所造成的，在jdbc连
ShardingSphere-JDBC实战
一、环境准备1.数据库创建2个库2个表：xdclass_shop_order_0product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1xdclass_shop_order_1product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1数据
Springboot整合JDBC
编写配置文件(application.yml)spring:datasource:username:rootpassword:123456url:jdbc:mysql://localhost:3306/mybatis?useUnicode&characterEncoding=utf-8driver-class-name:com.mysql.cj.jdbc.Driver测试连接@SpringBootTestclassSprin
ssm相关配置
结构图pom.xml<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http:/
MySql JDBC url 参数详解
MySql链接url参数详解 jdbc:mysql://[host:port],[host:port].../[database][?参数名1][=参数值1][&参数名2][=参数值2]... 常用的几个较为重要的参数： 参数名称参数说明缺省值最低版本要求 user 数据库用户名（用于连接数据库） 所有版本passWord用户密码（用于连接
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot