这篇文章给大家介绍如何在Java中操作JDBC连接数据库,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
JDBC全称又叫做Java DataBase Connectivity,也就是Java数据库连接,说白了就是用Java语言来操作数据 库,提供统一API访问数据库操作。
JDBC主要是用于java连接数据库的,能连接什么数据库不固定,其实能连接很多种数据库,而且一般来说可以连接oracle和mysql,通常也是这两种。但是既然JDBC能连接这么多的数据库,开发起来太麻烦了,于是sun公司那些人想出了一个办法,我定义一套规范,大家都按照这个规范来,实现自己公司访问数据库的实现。这套规范就是JDBC,遵循了JDBC规范的,可以访问自己数据库的API被称之为数据库驱动。
数据库操作分为6个步骤(增、删、改可跳过第5步,移步看第6步):
1、首先,项目中检查是否已导入mysql连接jar包,如:mysql-connector-java-5.1.6-bin.jar
2、使用反射注册数据库驱动,Class.forName(name);
3、通过DriverManager.getConnection(url, username, password)构造器获取数据库连接
4、通过Connection连接对象获取数据库操作对象PrepareStatement或者Statement
5、通过获取的Statement对象执行executeQuery()操作返回ResultSet结果集,需判断是否为空
6、通过获取的Statement对象执行executeUpdate()操作返回受影响的行数,判断是否成功标识
7、释放连接资源,关闭顺序为:ResultSet -> PrepareStatement / Statement -> Connection
解释说明关键类:
(1)DriverManager:该类管理数据库驱动程序。
(2)Connection:管理数据库建立的连接。
(3)Statement:负责将要执行的sql体提交到数据库。
(4)ResultSet:执行sql查询语句返回的结果集。
(5)PreparedStatement: 可以使用预编译的SQL,防止SQL注入,而Statment只能使用静态的SQL。
PreparedStatement 与 Statment 区别:
语法不同: PreparedStatement可以使用预编译的sql,而Statment只能使用静态的sql。
效率不同: PreparedStatement可以使用sql缓存区,效率比Statment高。
安全性不同: PreparedStatement可以有效防止sql注入,而Statment不能防止sql注入。
工具类(可做相对应灵活替换):
package com.bnd.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Objects; /** * @author 作者 mbql: * @version 创建时间:2021年1月10日 下午5:14:16 * 类说明 JDBC操作数据库工具类 */ public class JdbcUtils { private static final String driverName = "com.mysql.jdbc.Driver"; // 数据库驱动名称 private static final String url = "jdbc:mysql://39.108.146.20:3307/jsp?useUnicode=true&characterEncoding=utf-8"; // 数据库url private static final String userName = "root"; // 用户名 private static final String password = "123456"; // 用户密码 private static Connection conn = null; // 数据库连接对象 private static PreparedStatement preparedStatement = null; // 执行操作对象 static { try { Class.forName(driverName); // 2、注册数据库驱动 conn = DriverManager.getConnection(url, userName, password); // 3、获取数据库连接 } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 查询数据 * @return 返回查询到结果 */ public static ResultSet queryData() { ResultSet result = null; String sql = "select id, name, pwd from user"; // 定义预编译SQL try { preparedStatement = conn.prepareStatement(sql); // 4、执行预编译SQL操作 result = preparedStatement.executeQuery(); // 5、执行查询操作 while (result.next()) { int id = result.getInt(1); String name = result.getString(2); String pwd = result.getString(3); System.out.println("id:" + id + "--> name:" + name + "--> pwd:" + pwd); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、释放资源 close(conn, preparedStatement, result); } return result; } /** * 添加数据 * @return 返回受影响行数 */ public static int addData() { String sql = "insert into user(name,pwd) values(?, ?)"; try { preparedStatement = conn.prepareStatement(sql); // 4、执行预编译SQL操作 preparedStatement.setString(1, "tom"); preparedStatement.setString(2, "abc123"); int count = preparedStatement.executeUpdate(); // 6、执行添加操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、释放资源 close(conn, preparedStatement, null); } return -1; } /** * 更新数据 * @return 返回受影响行数 */ public static int updateData() { String sql = "update user set name = ?, pwd = ? where id = ?"; try { preparedStatement = conn.prepareStatement(sql); // 4、执行预编译SQL操作 preparedStatement.setString(1, "sueno"); preparedStatement.setString(2, "qwe123"); preparedStatement.setInt(3, 10); int count = preparedStatement.executeUpdate(); // 6、执行添加操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、释放资源 close(conn, preparedStatement, null); } return -1; } /** * 删除数据 * @return 返回受影响行数 */ public static int deleteData() { String sql = "delete from user where id = ?"; try { preparedStatement = conn.prepareStatement(sql); // 4、执行预编译SQL操作 preparedStatement.setInt(1, 11); int count = preparedStatement.executeUpdate(); // 6、执行添加操作 if (count > 0) { return count; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { // 7、释放资源 close(conn, preparedStatement, null); } return -1; } /** * 释放资源 * @param conn 关闭数据库连接 * @param statement 关闭数据库操作对象 * @param rs 关闭结果集操作对象 */ public static void close(Connection conn, Statement statement, ResultSet rs) { if (Objects.nonNull(rs)) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (Objects.nonNull(statement)) { try { statement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (Objects.nonNull(conn)) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
测试类:
package com.bnd.util; import java.sql.ResultSet; /** * @author 作者 mbql: * @version 创建时间:2021年1月10日 下午6:00:30 * 类说明 */ public class TestJdbc { public static void main(String[] args) { // 获取用户数据 // ResultSet rs = JdbcUtils.queryData(); // System.out.println(rs); // 添加用户数据 // int count = JdbcUtils.addData(); // if (count > 0) { // System.out.println("添加成功!"); // } // 更新用户数据 // int count = JdbcUtils.updateData(); // if (count > 0) { // System.out.println("更新成功!"); // } // 删除用户数据 // int count = JdbcUtils.deleteData(); // if (count > 0) { // System.out.println("删除成功!"); // } } }
1、通过简单Jdbc连接数据库,巧妙的实现了CRUD;其实实现并不难,记一下数据库连接步骤就行。
2、数据库操作本身就是一套数据库规范,根据不同驱动能够达到连接不同的数据库,实现可实行操作。
3、剧上述连接可知,数据库连接是非常耗性能的,频繁的数据库操作,不及时释放资源,会导致IO阻塞。
关于如何在Java中操作JDBC连接数据库就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。