学习笔记—JDBC

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

JDBC的概念

　　JDBC（Java DataBase Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。

 

JDBC的使用流程

 导入jar包

　　1、下载有关数据库的jar包（下载地址：http://central.maven.org/maven2/mysql/mysql-connector-java/）

　　2、导入jar包，在Build Path里配置环境

　　　　Build Path-->Add JARs

加载驱动

// 加载驱动程序：Class.forName(driverClass)

// 加载mysql驱动：
Class.forName("com.mysql.jdbc.Driver");
Class.forName("com.mysql.cj.jdbc.Driver");    // 8.0版本以后的mysql驱动

// 加载oracle驱动：
Class.forName("oracle.jdbc.driver.OracleDriver");

获取数据库连接对象

String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "123456";
Connection conn = DriverManager.getConnection(url, user, password);

　　参数含义：

　　　　url: 表示要连接的数据地址

　　　　user: 数据库的用户名

　　　　password: 数据库的密码

　　作用：

　　　　连接到指定的数据库并返回连接对象。

创建sql命令对象(编译和发送sql命令给数据库)

Statement stmt = conn.createStatement();

创建sql命令

String sql = "insert into user values(13,'王13','wang13')";

指定sql命令，获得返回结果

int i = stmt.executeUpdate(sql);
ResultSet rs = stmt.executeQuery(sql)

　　增删改 时调用 stmt.executeUpdate(sql)方法。返回值为 int类型。大于等于 1 时表示成功，为 0 时表示失败。　　

　　查询 调用 stmt.executeQuery(sql)方法。返回ResultSet 类型，表示一个结果集。

　　ResultSet对象是基于指针进行数据存储的，类似枚举。不便于数据的针对性的获取。可将数据转换到ArrayList中进行存储。

关闭资源

        stmt.close();
        conn.close();

　　关闭之前打开的资源。需要抛出异常。

 

对数据的增删改查

增加 （insert）

        // 声明jdbc变量
        Connection conn = null;
        Statement stmt = null;    
        // 声明jdbc参数
        String driver = "com.mysql.cj.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "123456";     
        try {
            // 1 加载驱动类
            Class.forName(driver);       
            // 2.获取数据库连接对象（连接指定数据库）
            conn = DriverManager.getConnection(url, user, password);         
            // 3.创建sql命令对象(编译和发送sql命令给数据库)
            stmt = conn.createStatement();          
            // 4.创建sql命令
            String sql = "insert into user values(13,'王13','wang13')";       
            // 5.指定sql命令
            int i = stmt.executeUpdate(sql);
            System.out.println("执行结果：" + i);      
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            // 6.关闭资源
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

 修改 （update）

        // 声明jdbc变量
        Connection conn = null;
        Statement stmt = null;

        // 声明jdbc参数
        String driver = "com.mysql.cj.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "123456";

        try {
            // 1 加载驱动类
            Class.forName(driver);

            // 2.获取数据库连接对象（连接指定数据库）
            conn = DriverManager.getConnection(url, user, password);

            // 3.创建sql命令对象(编译和发送sql命令给数据库)
            stmt = conn.createStatement();

            // 4.创建sql命令
            String sql = "update user set username='王update' where id=13";

            // 5.指定sql命令
            int i = stmt.executeUpdate(sql);
            System.out.println("执行结果：" + i);

        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            // 6.关闭资源
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

 删除 （delete）

        // 声明jdbc变量
        Connection conn = null;
        Statement stmt = null;

        // 声明jdbc参数
        String driver = "com.mysql.cj.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "123456";

        try {
            // 1 加载驱动类
            Class.forName(driver);

            // 2.获取数据库连接对象（连接指定数据库）
            conn = DriverManager.getConnection(url, user, password);

            // 3.创建sql命令对象(编译和发送sql命令给数据库)
            stmt = conn.createStatement();

            // 4.创建sql命令
            String sql = "delete from user where id=11";

            // 5.指定sql命令
            int i = stmt.executeUpdate(sql);
            System.out.println("执行结果：" +  i);

        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            // 6.关闭资源
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

查询（select）

        // 声明jdbc变量
        Connection conn = null;
        Statement stmt = null;    
        // 声明jdbc参数
        String driver = "com.mysql.cj.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "123456";
        try {
            // 1 加载驱动类
            Class.forName(driver);
            // 2.获取数据库连接对象（连接指定数据库）
            conn = DriverManager.getConnection(url, user, password);
            // 3.创建sql命令对象(编译和发送sql命令给数据库)
            stmt = conn.createStatement();
            // 4.创建sql命令
            String sql = "select * from user";
            // 5.指定sql命令
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt(1) + "  " + rs.getString("username") + "  " + rs.getString(3));
            }
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            // 6.关闭资源
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

　　

JDBC的事务管理

　　事务：一个事件的完成需要几个子操作的联合完成。只要有一个子操作执行失败，则数据回滚到原始状态，都成功则提交数据。

　　JDBC默认为自动提交事务。进行增删改操作时应将其设置为手动提交。

conn.setAutoCommit(false);

　　默认值为true，自动提交。 false 为手动提交。

　　使用try catch进行SQL命令执行提交和回滚。

        try {
            conn.commit();
        } catch (SQLException e) {
            conn.rollback();
            e.printStackTrace();
        }

　　try 中使用 conn.commit() 进行数据提交，若报错则在 catch 中使用 conn.rollback() 进行事务回滚。

 

使用PreparedStatement对象进行数据库操作

PreparedStatement对象与Statement对象的比较

　　Statement对象进行数据库操作时可能会出现 sql 注入的风险。

　　preparedStatement对象在sql语句中使用占位符，可以防止sql注入。可以预编译，批量执行同一条SQL语句时效率远大于Statement对象。

// statement对象执行sql语句
Statement stmt = conn.createStatement();
String sql = "insert into user values(13,'王13','wang13')";        
int i = stmt.executeUpdate(sql);


// preparedStatement对象执行sql语句
String sql = "insert into user values(?,?,?)";
PraparedStatement ps = conn.prepareStatement(sql);
ps.setInt(1, 15);
ps.setString(2, "王15");
ps.setString(3, "123456");
int i = ps.executeUpdate();

 优化封装代码

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/test
user=root
password=123456
db.properties 

 1 import java.io.IOException;
 2 import java.io.InputStream;
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.PreparedStatement;
 6 import java.sql.ResultSet;
 7 import java.sql.SQLException;
 8 import java.sql.Statement;
 9 import java.util.Properties;
10 
11 public class JUtil {
12     private static String driver;
13     private static String url;
14     private static String user;
15     private static String password;
16     
17     static {
18         // 创建properties对象获取属性文件的内容
19         Properties p = new Properties();
20         // 获取属性文件的读取对象流
21         InputStream is = JUtil.class.getResourceAsStream("/db.properties");
22         try {
23             // 加载属性配置文件
24             p.load(is);
25             // 获取jdbc参数
26             driver = p.getProperty("driver");
27             url = p.getProperty("url");
28             user = p.getProperty("user");
29             password = p.getProperty("password");
30             // 加载驱动
31             Class.forName(driver);
32         } catch (IOException e) {
33             // TODO Auto-generated catch block
34             e.printStackTrace();
35         } catch (ClassNotFoundException e) {
36             // TODO Auto-generated catch block
37             e.printStackTrace();
38         }
39     }
40     
41     // 获取Connection对象
42     public static Connection getConn() {
43         Connection conn = null;
44         try {
45             conn = DriverManager.getConnection(url, user, password);
46         } catch (SQLException e) {
47             // TODO Auto-generated catch block
48             e.printStackTrace();
49         }
50         return conn;
51     }
52     
53     // 获取PreparedStatement对象
54     public static PreparedStatement getPre(Connection conn,String sql) {
55         PreparedStatement ps = null;
56         try {
57             ps = conn.prepareStatement(sql);
58         } catch (SQLException e) {
59             // TODO Auto-generated catch block
60             e.printStackTrace();
61         }
62         return ps;
63     }
64     
65     // 关闭资源
66     public static void closeAll(Statement stmt,Connection conn) {
67         try {
68             stmt.close();
69         } catch (SQLException e) {
70             // TODO Auto-generated catch block
71             e.printStackTrace();
72         }
73         try {
74             conn.close();
75         } catch (SQLException e) {
76             // TODO Auto-generated catch block
77             e.printStackTrace();
78         }
79     }
80 }
工具类Jutil 

 1         /**
 2      * 封装DML
 3      * @param sql    sql语句
 4      * @param objs    参数数组
 5      * @return i 大于等于 1 时执行成功，等于 0 时执行失败。
 6      */
 7     private int executeDML(String sql,Object ... objs) {
 8         Connection conn = null;
 9         PreparedStatement ps = null;
10         int i= 0;
11         try {
12             // 创建连接对象
13             conn = JUtil.getConn();
14             // 手动提交事物
15             conn.setAutoCommit(false);
16             // 获得sql语句及参数
17             ps = JUtil.getPre(conn, sql);
18             // 给占位符赋值
19             for(int j = 0; j < objs.length; j++) {
20                 ps.setObject(j+1, objs[j]);
21             }
22             // 执行sql命令
23             i = ps.executeUpdate();
24             // 提交
25             conn.commit();
26         } catch (SQLException e) {
27             try {
28                 // 回滚
29                 conn.rollback();
30             } catch (SQLException e1) {
31                 e1.printStackTrace();
32             }
33         } finally {
34             JUtil.closeAll(ps, conn);
35         }
36         return i;
37     }
封装DML(增删改) 

 1     /**
 2      * 增加
 3      * @param id
 4      * @param name
 5      * @param pwd
 6      * @return  i 大于等于 1 时执行成功，等于 0 时执行失败。
 7      */
 8     public int insert(int id,String name,String pwd) {
 9         String sql = "insert into user values(?,?,?)";
10         int i = executeDML(sql,id,name,pwd);
11         return i;
12     }
insert增加 

 1     /**
 2      * 修改
 3      * @param id
 4      * @param name
 5      * @param pwd
 6      * @return  i 大于等于 1 时执行成功，等于 0 时执行失败。
 7      */
 8     public int update(int id,String name,String pwd) {
 9         String sql = "update user set username=? where id=?";
10         int i = executeDML(sql,name,id);
11         return i;
12     }
update修改 

 1     /**
 2      * 删除
 3      * @param id
 4      * @param name
 5      * @param pwd
 6      * @return  i 大于等于 1 时执行成功，等于 0 时执行失败。
 7      */
 8     public int delete(int id,String name,String pwd) {
 9         String sql = "delete from user where id=?";
10         int i = executeDML(sql, id);
11         return i;
12     }
delete删除 

 1     /**
 2      * 查询
 3      * @return
 4      */
 5     public List<User> select() {
 6         Connection conn = JUtil.getConn();
 7         String sql = "select * from user";
 8         PreparedStatement ps =  JUtil.getPre(conn, sql);
 9         List<User> us = new ArrayList<User>();
10         try {
11             ResultSet rs = ps.executeQuery();
12             while(rs.next()) {
13                 User u = new User();
14                 u.setId(rs.getInt(1));
15                 u.setName(rs.getString(2));
16                 u.setPwd(rs.getString(3));
17                 us.add(u);
18             }
19         } catch (SQLException e) {
20             e.printStackTrace();
21         } finally {
22             JUtil.closeAll(ps, conn);
23         }
24         return us;
25     }
select查询

 

原文地址：https://www.cnblogs.com/shangyang/p/10594058.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