为什么要用jdbc(用了多年的框架)

为什么要用jdbc(用了多年的框架)(1)

JDBC基本操作

create table user( id int primary key auto_increment, name varchar(50) ) ENGINE = InnoDB DEFAULT CHARSET = utf8;

JDBC概念

JDBC是一个独立于特定数据库管理系统、通用的SQL数据库存取和操作的公共接口,定义了用来访问数据库的标准的Java类库

连接步骤
  • 加载驱动
  • 进行数据库连接

// 驱动 private static final String DRIVER = "com.mysql.jdbc.Driver"; // 地址 private static final String URL = "jdbc:mysql://localhost:3306/test"; //用户名 private static final String USER_NAME = "root"; // 密码 private static final String PSW = "123456"; /** * 获取连接 */ public static Connection getConnection(){ Connection conn = null; try { // 加载驱动 Class.forName(DRIVER); // 数据库连接 conn = DriverManager.getConnection(URL,USER_NAME,PSW); } catch (ClassNotFoundException e) { System.out.println("加载驱动失败,请检查是否引入Jar包或者驱动名称是否正确"); throw new RuntimeException("加载驱动失败,请检查是否引入Jar包或者驱动名称是否正确",e); } catch (SQLException throwables) { System.out.println("连接数据库失败,请检查数据库地址,用户名,密码是否正确"); throw new RuntimeException("连接数据库失败,请检查数据库地址,用户名,密码是否正确",throwables); } return conn; } /** * 关闭连接 * @param conn */ public static void close(Connection conn){ if(conn != null){ try { conn.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } }

注意:为什么需要使用Class.forName()来加载数据库驱动

是因为在每个Driver中都包含有一个静态代码块,实际调用的是DriverManager.registerDriver(new Driver());方法

public class Driver extends NonRegisteringDriver implements java.sql.Driver { public Driver() throws SQLException { } static { try { DriverManager.registerDriver(new Driver()); } catch (SQLException var1) { throw new RuntimeException("Can't register driver!"); } } }

DriverManager

该类进行数据库驱动的管理,可以注册多个数据库驱动,根据url来动态的选择不同的数据库连接。

操作数据库Statement接口

使用Statement接口来操作静态的SQL语句

executeUpdate方法添加

/** * 插入操作 * @param sql */ public static void doInsert(String sql){ Connection conn = getConnection(); Statement statement = null; try { statement = conn.createStatement(); int result = statement.executeUpdate(sql); System.out.println(sql "执行成功,插入" result "条数据"); } catch (SQLException e) { throw new RuntimeException("执行失败",e); } finally { if(statement != null){ try { statement.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } close(conn); } }

修改

/** * 修改操作 * @param sql */ public static void doUpdate(String sql){ Connection conn = getConnection(); Statement statement = null; try { statement = conn.createStatement(); int result = statement.executeUpdate(sql); System.out.println(sql "执行成功,修改" result "条数据"); } catch (SQLException e) { throw new RuntimeException("执行失败",e); } finally { if(statement != null){ try { statement.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } close(conn); } }

删除

/** * 删除操作 * @param sql */ public static void doDelete(String sql){ Connection conn = getConnection(); Statement statement = null; try { statement = conn.createStatement(); int result = statement.executeUpdate(sql); System.out.println(sql "执行成功,删除" result "条数据"); } catch (SQLException e) { throw new RuntimeException("执行失败",e); } finally { if(statement != null){ try { statement.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } close(conn); } }

PreparedStatement接口

该接口为Statement的子接口,属于预处理操作,可以传入带有占位符的SQL,然后再进行补充占位符,索引值从1开始。

可以有效地禁止SQL注入

executeUpdate方法插入

public static void doPreparedInsert(String name){ Connection conn = getConnection(); PreparedStatement statement = null; try { String sql = "insert into user (name) values (?)"; statement = conn.prepareStatement(sql); statement.setString(1,name); int result = statement.executeUpdate(); System.out.println(sql "执行成功,插入" result "条数据"); } catch (SQLException e) { throw new RuntimeException("执行失败",e); } finally { if(statement != null){ try { statement.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } close(conn); } }

在创建preparedStatement对象时,有一个重载方法

// 第二个参数表示一个是否返回自增主键的一个biaoshi // Statement.RETURN_GENERATED_KEYS // Statement.NO_GENERATED_KEYS PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)

在使用该PreparedStatement执行插入操作时,可以使用statement.getGeneratedKeys()来返回一个新生成主键的ResultSet对象,结果集中只有一列GENERATED_KEY,存放的新生成的主键值

更新

与插入类似

删除

与插入类似

结果集

在查询数据时,返回的是一个二维的结果集,使用ResultSet来遍历结果集

public static void doQuery(){ String sql = "select * from user"; Connection conn = getConnection(); PreparedStatement statement = null; ResultSet resultSet = null; try { statement = conn.prepareStatement(sql); resultSet = statement.executeQuery(); // resultSet.next 方法 将光标向前移动一行,最初为第一行之前,第一次调用使得第一行为当前行 while (resultSet.next()){ int id = resultSet.getInt("id"); String name = resultSet.getString("name"); System.out.println("查询到id为" id ",name为" name "的记录"); } } catch (SQLException throwables) { throwables.printStackTrace(); } finally { if(resultSet != null){ try { resultSet.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } close(conn,statement); } }

批量操作

public static void doBatchInsert(String sql){ Connection conn = getConnection(); PreparedStatement statement = null; try { statement = conn.prepareStatement(sql); for(int i = 0;i<1000;i ){ statement.setString(1,"张三" i); // 积攒sql statement.addBatch(); } // 执行sql statement.executeBatch(); // 清除积攒的sql statement.clearBatch(); } catch (SQLException throwables) { throwables.printStackTrace(); } finally { close(conn,statement); } }

,

免责声明:本文仅代表文章作者的个人观点,与本站无关。其原创性、真实性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容文字的真实性、完整性和原创性本站不作任何保证或承诺,请读者仅作参考,并自行核实相关内容。文章投诉邮箱:anhduc.ph@yahoo.com

    分享
    投诉
    首页