JDBC基础语句使用

阅读量：5898 次

发布时间：2019-06-19

本文共 10457 字，大约阅读时间需要 34 分钟。

1 /* 2      *     插入数据 　　　　　*第一步：创建JDBC四大参数 　　　　　*第二步：加载驱动

　　　　　*第三步：定义要传入的sql语句 　　　　　*第四步：创建连接通道 　　　　　*第五步：执行给定的SQL语句  3      */ 4     @Test 5     public void test2() throws ClassNotFoundException, SQLException { 6         // JDBC四大参数 7         String driverClassName = "com.mysql.jdbc.Driver"; 8         // 创建连接 9         String url = "jdbc:mysql://localhost:3306/db2";10         String user = "root";11         String password = "123";12         // 加载驱动 相当于 com.mysql.jdbc.Driver  driverClassName = new com.mysql.jdbc.Driver();13         Class.forName(driverClassName);// 加载Driver这个类,该类实现了java.sql.Driver的驱动14         //创建连接 连接Java程序和数据之间一个通道15         Connection connection = DriverManager.getConnection(url, user, password);16         //要传入的SQL语句17         String sql = "INSERT INTO stu values (57,'张三',18,'男','四川',1200)";18         // 创建一个 Statement 对象来将 SQL 语句发送到数据库。19         Statement statement = connection.createStatement();20         // 执行给定 SQL 语句,该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句（如 SQL DDL 语句）。21         //返回受影响的语句的行数22         statement.executeUpdate(sql);23 24     }

1     public void test3() { 2 //        登录验证 3         Scanner sc = new Scanner(System.in); 4         Connection connection = null; 5         ResultSet row = null; 6         Statement statement = null; 7         try { 8 //            创建联接 9             connection = JdbcUtil.getConnection();10 11             System.out.println("请输入姓名");12             String sname = sc.nextLine();13             System.out.println("请输入年龄");14             int sage = sc.nextInt();15 //        整理sql语句16             String sql = "select * from stu where sname ='" + sname + "' and " + "sage = '" + sage + "' ";17 //        传递数据18             statement = connection.createStatement();19             row = statement.executeQuery(sql);20             if (row.next()) {21                 System.out.println("登录成功");22             } else {23                 System.out.println("登录失败");24             }25         } catch (SQLException e) {26             e.printStackTrace();27         } finally {28             sc.close();29 30             try {31                 if (row.next()) {32                     row.close();33                 }34 35             } catch (SQLException e) {36                 e.printStackTrace();37             }38         }39 40     }

由于每次连接很麻烦，所以可以封装一个方法，作为JDBC工具包，返回值是Connection对象，使用配置文件来传递我们想要的四大参数

1 import java.io.FileInputStream; 2 import java.io.FileNotFoundException; 3 import java.io.IOException; 4 import java.sql.Connection; 5 import java.sql.DriverManager; 6 import java.sql.SQLException; 7 import java.util.Properties; 8 /* 9 *jdbc工具包10 /11 public class myUtil {12     static Properties property = new Properties();13 //    Class.forName(driverClassName)14     static {15         try {16             property.load(new FileInputStream("db2.properties"));17             Class.forName(property.getProperty("driverClassName"));18             }19         catch (ClassNotFoundException e) {20                 e.printStackTrace();21         } catch (FileNotFoundException e) {22             e.printStackTrace();23         } catch (IOException e) {24             e.printStackTrace();25         }26     }27     public static  Connection getConnection() throws SQLException {28         String url =property.getProperty("url");29         String user =property.getProperty("user");30         String password =property.getProperty("password");31         32         return DriverManager.getConnection(url, user, password);33         34     }35 }36 /*37 *测试方法38 */39     @Test40     public void test4() throws SQLException {
   // 修改数据41 //        获取联接42         Connection connection = myUtil.getConnection();43         String sql = "update stu set sname = ? ,sage = ? where sid = 1";44 //        传递数据45         PreparedStatement prep = connection.prepareStatement(sql);46         prep.setString(1, "张思");47         prep.setInt(2, 15);48         int executeUpdate = prep.executeUpdate();49         System.out.println(executeUpdate);50 51     }

1.使用别人封装好的jar包，好像还有连接池

2.使用PreparedStatement代替Statement，它的优点:使用？作为占位符，语句预编译，执行效率高;可以避免注入攻击（就是第二个登录方法里面输入das' or 1=1 -- dad das 也会登录成功）

1 import java.sql.Connection; 2 import java.sql.SQLException; 3  4 import com.mchange.v2.c3p0.ComboPooledDataSource; 5  6 public class JdbcUtil { 7     private static ComboPooledDataSource  datasource = new ComboPooledDataSource(); 8  9     //获取连接10     public static Connection getConnection() throws SQLException {11         return datasource.getConnection();12     }13 }14 15 16     @Test17     public void test5() throws SQLException {
   // 添加数据18         Scanner sc = new Scanner(System.in);19 //        获取连接20         Connection connection = JdbcUtil.getConnection();21 //        传递数据22         String sql = "insert into stu(sid,sname,sage) values (?,?,?)";23         PreparedStatement prepareStatement = connection.prepareStatement(sql);24         System.out.println("输入要添加的ID");25         int sid = sc.nextInt();26         System.out.println("输入要添加的名字");27         String sname = sc.next();28         System.out.println("输入要添加的年龄");29         int sage = sc.nextInt();30         prepareStatement.setInt(1, sid);31         prepareStatement.setString(2, sname);32         prepareStatement.setInt(3, sage);33 //        请求输入数据34         int executeUpdate = prepareStatement.executeUpdate();35         System.out.println(executeUpdate);36 37     }

在Eclipse中使用事务处理，实现账户转账中的问题

1     /* 2      * ui层 3      */ 4     public static void main(String[] args) { 5         Test01 t = new Test01(); 6         try { 7             t.backService("张三", "李四", 100); 8         } catch (Exception e) { 9             System.out.println("转账失败");10         }11     }12 13     /*14      * service层的转账方法15      */16     public void backService(String from, String to, int money) throws Exception {
   // 事务操作,保证转账正常17 //        创建同一个连接18         Connection con = null;19         try {20             // 通过工具包创建与数据库的连接21             con = JdbcUtil.getConnection();22             // 开启手动事务23             con.setAutoCommit(false);24             // 调用dao层更新要存储的数据 ,from账户中的钱减少,to账户中的钱增多25             updateAccount(con, from, -money);26             //人为制造一个异常,假设from 转账成功 ,但是to没有收到钱,看数据库的数据回滚没有27 //            if(true) throw new Exception();  //当开启异常是转账失败,数据回滚 ,当关闭时成功转账28             updateAccount(con, to, money);29             //如果正常执行,则提交事务,此时数据库的值会改变  commit 承诺30             con.commit(); 31         } catch (SQLException e) {32             //出现异常的处理方式是回滚事务(意思就是更改的信息不保存到数据库,还原到调用之前)33              try {34                 con.rollback();35             } catch (SQLException e1) {36                 System.out.println("回滚失败");37             }38         }39     }40 41     /*42      * dao层执行数据的存储的方法43      */44     public void updateAccount(Connection con, String bname, int bbalan) throws SQLException {45         // 已经创建连接,可以传递数据,使用mysql 语句46         String sql = "update back set bbalan = bbalan + ? where bname = ? ";47         PreparedStatement prepareStatement = con.prepareStatement(sql);48         prepareStatement.setInt(1, bbalan);49         prepareStatement.setString(2, bname);50 //        请求修改51         prepareStatement.executeUpdate();52 53     }54 55 }

1 /* 2  * 执行查询操作，如果rs查询结果不为空，如果有下一个值，就取出值，数据库中的字段是 id int,name varchar(10),address varchar(10) 3  * 获取查询结果有两种方式，一种是通过列索引，第一个的索引为一;第二种是通过列字段作为参数获取 4  */ 5     @Test 6     public void test02() throws ClassNotFoundException, SQLException { 7         Connection connection = JdbcUtils.getConnection(); 8         //查询操作: 9         String sql="select * from student"; 　　　　　　　//预编译sql语句，如果发现第二次调用的sql语句和第一次相同，则用以前的10         Statement statement = connection.createStatement();11         //executeQuery()用来执行查询，结果ResultSet中存储的是查询结果12         ResultSet rs = statement.executeQuery(sql);13         if(rs!=null) {14             while(rs.next()) {15                 //JDBC的下标从1开始16                 System.out.println(rs.getInt(1));17                 System.out.println(rs.getString(2));18                 System.out.println(rs.getString("address"));19             }20         }21         rs.close();22         statement.close();23         connection.close();24     }

JDBC:JDBC（Java DataBase Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用编写的类和接口组成。

意思就是通过Java代码操作数据库

常见的JDBC组件：

JDBC API提供了以下接口和类：

DriverManager:

概念: 属于java.sql包,用于管理数据库驱动程序的类

作用：处理驱动程序的加载和建立新数据库连接

常用静态方法：
getConnection(String url,String userName,String password) ,该方法返回一个Connection类对象

Driver: 此接口处理与数据库服务器的通信。

Connection :

Connection接口的实现类即上文的Connection类，概念及作用等同。

作用：

（1）Connection对象表示数据库的连接状态；- - 保存DriverManager()方法的返回值。

（2） Connection接口提供了多种数据库操作的方法：

常用的几种方法：
1.处理sql语句（常用的三种如下）： - - 处理的过程：编译/预编译sql语句，还没执行
(1) stamement(String sql) - - 返回的是一个Statement对象
(2) preparedStatement(String sql) - - 返回的是一个PreparedStatement对象
(3)callabStatement(String sql) - - 返回的是一个CallabStatement对象
2.控制事务提交
(1) setAutoCommit(true/false) - - true为打开自动提交，false为关闭自动提交。（默认自动提交）
3.控制事务回滚
rollback()
4.关闭数据库连接
close()