原生JDBC

JDBC
Java DataBase Connectivity,java数据库连接,是一种用于执行SQL语句的Java API。
JDBC是Java访问数据库的标准规范,可以为不同的关系型数据库提供统一访问,它由一组用Java语言编写的接口和类组成。

驱动
JDBC需要连接驱动,驱动是两个设备要进行通信,满足一定通信数据格式,数据格式由设备提供商规定,设备提供商为设备提供驱动软件,通过软件可以与该设备进行通信。

JDBC规范(掌握四个核心对象
DriverManager:用于注册驱动
Connection: 表示与数据库创建的连接
Statement: 操作数据库sql语句的对象
ResultSet: 结果集或一张虚拟表

使用JDBC技术,通过mysql提供的驱动程序,操作数据库实现步骤:
1.注册驱动
告知JVM我们使用的是什么驱动程序(mysql,oracle....)
DriverManager.registerDriver(new com.mysql.jdbc.Driver());不建议使用
原因有2个:
>导致驱动被注册2次。
>强烈依赖数据库的驱动jar
解决办法:
Class.forName("com.mysql.jdbc.Driver");
2.获取数据库的连接
数据库是TCP程序服务器,连接服务器(通过3次握手)
就相当于建立了一条java程序通往数据库服务器的连接通路
static Connection getConnection(String url, String user, String password)
试图建立到给定数据库 URL 的连接。
参数说明:url 需要连接数据库的位置(网址) user用户名 password 密码
例如:getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
URL:SUN公司与数据库厂商之间的一种协议。
jdbc:mysql://localhost:3306/day06
协议子协议 IP :端口号数据库
mysql: jdbc:mysql://localhost:3306/day04或者jdbc:mysql:///day14(默认本机连接)
oracle数据库: jdbc:oracle:thin:@localhost:1521:sid
3.获取执行者对象
执行SQL语句的对象,作用就是执行SQL
接口的实现在数据库驱动中。所有与数据库交互都是基于连接对象的。
Statement createStatement(); //创建操作sql语句的对象
4.执行SQL语句,获取结果集
使用执行者对象执行SQL语句
获取SQL语句的结果集(增删改:整数,执行有效行数 查询:返回的就是一个结果集)
常用方法:
? int executeUpdate(String sql); --执行insert update delete语句.
? ResultSet executeQuery(String sql); --执行select语句.
? boolean execute(String sql); --仅当执行select并且有结果时才返回true,执行其他的语句返回false.
5.处理结果集
ResultSet实际上就是一张二维的表格,我们可以调用其boolean next()方法指向某行记录,当第一次调用next()方法时,便指向第一行记录的位置,这时就可以使用ResultSet提供的getXXX(int col)方法(与索引从0开始不同个,列从1开始)来获取指定列的数据:
rs.next();//指向第一行
rs.getInt(1);//获取第一行第一列的数据
常用方法:
? Object getObject(int index) / Object getObject(String name) 获得任意对象
? String getString(int index)/ String getString(String name) 获得字符串
? int getInt(int index)/int getInt(String name) 获得整形
? double getDouble(int index)/ double getDouble(String name) 获得双精度浮点型
6.释放资源
与IO流一样,使用后的东西都需要关闭!关闭的顺序是先得到的后关闭,后得到的先关闭。
使用JDBC对数据库进行增删改查代码演示:

  1 public static void main(String[] args) throws Exception {
  2         //1.注册驱动
  3         Class.forName("com.mysql.jdbc.Driver");
  4         //2.获取数据库连接
  5         String url = "jdbc:mysql://localhost:3306/mybase4";
  6         String user = "root";
  7         String password = "root";
  8         Connection conn = DriverManager.getConnection(url, user, password);
  9         //3.获取执行者对象
 10         Statement stat = conn.createStatement();
 11         //调用更新数据的方法
 12         //update(stat);
 13         //调用删除数据的方法
 14         //delete(stat);
 15         //调用增加数据的方法
 16         //insert(stat);
 17         //调用查询数据的方法
 18         select(stat);
 19         //6.释放资源
 20         stat.close();
 21         conn.close();
 22     }
 23
 24     /*
 25      * 使用JDBC技术,查询数据库中表的数据
 26      */
 27     private static void select(Statement stat) throws Exception {
 28         //拼接sql语句
 29         String sql = "SELECT * FROM category";
 30         /*
 31          * 4.执行sql语句
 32          * 使用Statement中的方法
 33          * ResultSet executeQuery(String sql) 执行给定的 SQL 语句,该语句返回单个 ResultSet 对象。
 34          * 返回值ResultSet标准接口的实现类对象,实现类对象由mysql驱动提供,可以使用ResultSet接口接收
 35          */
 36         ResultSet rs = stat.executeQuery(sql);
 37         System.out.println(rs);//[email protected]
 38         /*
 39          * 5.处理结果
 40          * ResultSet中有一个方法
 41          * boolean next() 将光标从当前位置向前移一行。
 42          * 如果新的当前行有效,则返回 true;如果不存在下一行,则返回 false
 43          * 如果有结果集返回true,若果没有结果集返回false
 44          * 相当于迭代器中的hasNext方法
 45          */
 46         while(rs.next()){
 47             /*
 48              * next返回true,有结果集
 49              * 取出结果集
 50              * 使用ResultSet中的方法getXXX(参数);
 51              * 参数:
 52              *     int columnIndex:列所在的索引,从1开始
 53              *     String columnLabel:列名
 54              * 注意:
 55              *     如果使用getInt,getDouble指定数据类型的方法,返回值就是对应的数据类型
 56              *     如果使用getObject方法返回值是object类型(只是打印可用)
 57              * 如果使用getString方法返回值是String类型
 58              */
 59             /*int i1 = rs.getInt(1);
 60             String s2 = rs.getString(2);
 61             System.out.println(i1+"\t"+s2);*/
 62
 63             //System.out.println(rs.getObject(1)+"\t"+rs.getObject(2));
 64             System.out.println(rs.getObject("cid")+"\t"+rs.getObject("cname"));
 65             //5.释放资源
 66             rs.close();
 67         }
 68     }
 69
 70     /*
 71      * 使用JDBC技术,对数据库中的表数据进行增加
 72      */
 73     private static void insert(Statement stat) throws SQLException {
 74         //拼接sql语句
 75         String sql = "INSERT INTO category(cname) VALUES(‘玩具‘)";
 76         //4.执行sql语句
 77         int row = stat.executeUpdate(sql);
 78         //5.处理结果
 79         if(row>0){
 80             System.out.println("增加数据成功!");
 81         }else{
 82             System.out.println("增加数据失败!");
 83         }
 84
 85     }
 86
 87     /*
 88      * 使用JDBC技术,对数据库中的表数据进行删除
 89      */
 90     private static void delete(Statement stat) throws Exception {
 91         //拼接sql语句
 92         String sql = "DELETE FROM category WHERE cid=5";
 93         //4.执行sql语句
 94         int row = stat.executeUpdate(sql);
 95         //5.处理结果
 96         if(row>0){
 97             System.out.println("删除数据成功!");
 98         }else{
 99             System.out.println("删除数据失败!");
100         }
101     }
102
103     /*
104      * 使用JDBC技术,对数据库中的表数据进行更新
105      */
106     private static void update(Statement stat) throws Exception {
107         //拼接sql语句
108         String sql = "UPDATE category SET cname=‘鞋帽‘ WHERE cid=6";
109         //4.执行sql语句
110         int row = stat.executeUpdate(sql);
111         //5.处理结果
112         if(row>0){
113             System.out.println("更新数据成功!");
114         }else{
115             System.out.println("更新数据失败!");
116         }
117     }
 1 JDBC工具类
 2 “获得数据库连接”操作,将在以后的增删改查所有功能中都存在,可以封装工具类JDBCUtils。提供获取连接对象的方法,从而达到代码的重复利用。
 3 代码演示:
 4 public class JDBCUtils {
 5
 6     //私有构造方法,防止外界创建对象调用方法
 7     private JDBCUtils() {
 8     }
 9
10     //定义Connectionn变量
11     private static Connection conn;
12
13     //保证代码只执行一次,可以放入静态代码块中
14     static{
15         try {
16             //注册驱动
17             Class.forName("com.mysql.jdbc.Driver");
18             //获取连接
19             String url="jdbc:mysql://127.0.0.1:3306/mybase4";
20             String user="root";
21             String password = "root";
22             conn = DriverManager.getConnection(url, user, password);
23         } catch (Exception e) {
24             //注意,如果连接数据库失败,停止程序
25             throw new RuntimeException(e+"连接数据库失败");
26         }
27     }
28
29     //创建一个静态方法,获取数据库连接对象,并返回
30     public static Connection getConnection(){
31         return conn;
32     }
33
34     /*
35      * 创建一个静态方法,对资源进行释放
36      * ResultSet rs
37      * Statement stat
38      * Connection conn
39      */
40     public static void close(ResultSet rs,Statement stat,Connection conn){
41         try {
42             if(rs!=null){
43                 rs.close();
44             }
45         } catch (SQLException e) {
46             e.printStackTrace();
47         }
48         try {
49             if(stat!=null){
50                 stat.close();
51             }
52         } catch (SQLException e) {
53             e.printStackTrace();
54         }
55         try {
56             if(conn!=null){
57                 conn.close();
58             }
59         } catch (SQLException e) {
60             e.printStackTrace();
61         }
62     }
63 }

sql注入问题
SQL注入:用户输入的内容作为了SQL语句语法的一部分,改变了原有SQL真正的意义。
假设有登录案例SQL语句如下:
SELECT * FROM 用户表 WHERE NAME = 用户输入的用户名 AND PASSWORD = 用户输的密码;
此时,当用户输入正确的账号与密码后,查询到了信息则让用户登录。但是当用户输入的账号为XXX 密码为:XXX’ OR ‘a’=’a时,则真正执行的代码变为:
SELECT * FROM 用户表 WHERE NAME = ‘XXX’ AND PASSWORD =’ XXX’ OR ’a’=’a’;
此时,上述查询语句时永远可以查询出结果的。那么用户就直接登录成功了,显然我们不希望看到这样的结果,这便是SQL注入问题。
为此,我们使用PreparedStatement来解决对应的问题。

preparedStatement:预编译对象,是Statement对象的子类。
特点:
性能高
会把sql语句先编译
能过滤掉用户输入的关键字。

PreparedStatement预处理对象,处理的每条sql语句中所有的实际参数,都必须使用占位符?替换。
String sql = "select * from user where username = ? and password = ?";
PreparedStatement使用,需要通过以下3步骤完成:
1.PreparedStatement预处理对象代码:
获得预处理对象,需要提供已经使用占位符处理后的SQL语句
PreparedStatement psmt = conn.prepareStatement(sql)
2.设置实际参数
void setXxx(int index, Xxx xx) 将指定参数设置指定类型的值
参数1:index 实际参数序列号,从1开始。
参数2:xxx 实际参数值,xxx表示具体的类型。
例如:
setString(2, "1234") 把SQL语句中第2个位置的占位符?替换成实际参数 "1234"
3.执行SQL语句:
int executeUpdate(); --执行insert update delete语句.
ResultSet executeQuery(); --执行select语句.
boolean execute(); --执行select返回true 执行其他的语句返回false.

时间: 2024-12-13 10:55:46

原生JDBC的相关文章

使用原生JDBC方式对数据库进行操作

使用原生JDBC方式对数据库进行操作,包括六个步骤: 1.加载JDBC驱动程序 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM.可以通过java.lang.Class类的静态方法forName(String className)实现,成功加载后,会将Driver类的实例注册到DriverManager类中. 代码如下: Class.forName("com.mysql.jdbc.Driver"); Class.forName()方法内部实现包括两部分:类加载.类初始化. 1

hibernate4使用原生jdbc进行批处理

在hibernate中,有一级缓存session和二级缓存sessionFactory这些机制,一方面为编码提供了便利,同时也会有一些副作用.比如有较大的数据量交互的话,缓存反而会降低效率.最近在做一个有关批量更新的程序,在调用session.update()之后,对象会保存在缓存中,如果数据量超过缓存的容量就会出错.解决方法是:在hibernate中调用jdbc批量处理的API,使用原生的jdbc来进行批量操作. 但是这里又出现了新的问题,在hibernate4中,通过session是不能直接

原生JDBC问题总结

使用JDBC查询MySQL中用户表的记录 数据库初始化 1 /* 2 SQLyog v10.2 3 MySQL - 5.1.72-community : Database - mybatis 4 ********************************************************************* 5 */ 6 7 8 /*!40101 SET NAMES utf8 */; 9 10 /*!40101 SET SQL_MODE=''*/; 11 12 /*!4

JAVA 使用原生jdbc批量添加,表被锁住问题

今天用jdbc批量添加数据的时候遇到了一个问题,当数据添加成功过后,再想对该表进行操作发现表被锁住了,检查了下代码发现事务提交了呀!!!!!!!!!!!! 去网上查了大半天的资料才发现问题,在connection  commit过后需要加上 connection.setAutoCommit(true); 下面是示例代码 log.info("插入语句" + sql); //获取结果集 connection = JdbcUtils.getConnection(database.getMys

原生jdbc执行存储过程

1 //定时任务,结转 . 2 //表名 fys_sch_lvyou2 ,存储过程名:fys_sch_lvyou2_carrayover 3 //无参调用:{call insertLine} 4 //有参调用:{call fys_sch_lvyou2_carrayover(?,?) 然后传递参数即可 5 public void startCarrayOver(){ 6 //获取要结转的时间:当前月(2016年09月30日)的上月,2016年08月 7 Calendar c = Calendar.

JDBC事务的相关知识

事务的定义 事务(Transaction):是并发控制的单元,是用户定义的一个操作序列.这些操作要么都做,要么都不做,是一个不可分割的工作单位.通过事务,sql server 能将逻辑相关的一组操作绑定在一起,以便服务器 保持数据的完整性. 事务的相关特性 用几个字母总结就是ACID. 1) 原子性(atomicity):事务是数据库的逻辑工作单位,而且是必须是原子工作单位,对于其数据修改,要么全部执行,要么全部不执行. 2) 一致性(consistency):事务在完成时,必须是所有的数据都保

sql-原生jdbc连接7步

原生jdbc链接一般分为7步, 来获取链接并执行sql语句 1, 准备4大参数 static { url = "jdbc:mysql://localhost:3306/test" ; driveClassName = "com.mysql.jdbc.Driver"; userName = "root" ; password = "root" ; } 2, 注册驱动 # 使用Class注册 Class.forName(drive

drill java && spring jdbc 连接使用

原生 jdbc 连接 1. maven 包 <dependency> <groupId>org.apache.drill.exec</groupId> <artifactId>drill-jdbc-all</artifactId> <version>1.10.0</version> </dependency> 2. 代码 Class.forName("org.apache.drill.jdbc.Dri

使用Spring简化JDBC操作数据库

Spring的开发初衷是为了减轻企业级开发的复杂度,其对数据库访问的支持亦如此,使用Spring访问数据库能带来以下好处: 1.1     简化代码 使用原生的JDBC访问数据库,一般总是要执行以下步骤: 1)         获取数据库资源,例如连接等: 2)         准备并执行SQL,并处理返回结果 3)         释放数据库资源 4)         处理上述所有步骤出现的异常,处理异常的过程中也要捕获异常 典型的代码结构如下: public TestObj queryTes