JDBC连接数据库步骤及基本操作示例详解
作者:bug生产者
这篇文章主要为大家介绍了JDBC连接数据库步骤及基本操作示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
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); } }
以上就是JDBC连接数据库步骤及基本操作示例详解的详细内容,更多关于JDBC连接基本操作的资料请关注脚本之家其它相关文章!