企业网站备案系统,网络公司做的网站根目录在哪,购物系统数据库设计,微信公众平台开发源码JDBC简介和使用 java程序操作数据库的方式有很多种#xff0c;下面列举一些市面上常用的方式#xff1a; 从图片分析的知#xff1a; MyBatis MyBatisPlus 这两个所占的比重比较大。都是用于简化JDBC开发的 JDBC#xff1a;(Java DataBase Connectivity)#xff0c;就…JDBC简介和使用 java程序操作数据库的方式有很多种下面列举一些市面上常用的方式 从图片分析的知 MyBatis MyBatisPlus 这两个所占的比重比较大。都是用于简化JDBC开发的 JDBC(Java DataBase Connectivity)就是使用Java语言操作关系型数据库的一套API。 JDBC的本质 sun公司官方定义的一套操作所有关系型数据库 各个数据库厂商去实现这套接口提供忽聚酷驱动jar包 我们使用这套接口JDBC编程真正执行的代码时驱动jar包中的实现类 快速入门 1创建项目引入mysql的驱动junit依赖 dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId version8.0.33/version/dependency 2注册驱动 Class.forName(com.mysql.cj.jdbc.Driver); 3获取连接对象Connection Connection connection DriverManager.getConnection( jdbc:mysql://localhost:3306/web, root, root1234) 4获取SQL语句自行对象statement Statement statement connection.createStatement(); 5 执行SQL语句 statement.executeUpdate(update user set password 1234567890 where id 1); 6 释放资源 statement.close();connection.close(); 1创建maven项目引入MySQL的驱动和junit单元测试的依赖 在工程下右击然后点击new选择Module 选择 New Module 然后根据自己情况完成右边的配置 创建好工程之后添加依赖。 2注册驱动 //注册驱动Class.forName(com.mysql.cj.jdbc.Driver); 3获取连接对象Connection // 获取连接对象Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/sde01,root,root); 4获取SQL语句自行对象statement // 获取执行SQL的对象
Statement statement connection.createStatement(); 5 执行SQL语句 //执行SQL
statement.executeUpdate(update user set password 666666 where id 1); 6 释放资源 statement.close();connection.close();
完整操作
这个数据库是我本地的sde01库中的user表
create table user(id int unsigned primary key auto_increment comment ID,主键,username varchar(20) comment 用户名,password varchar(32) comment 密码,name varchar(10) comment 姓名,age tinyint unsigned comment 年龄
) comment 用户表;insert into user(id, username, password, name, age) values (1, daqiao, 123456, 大乔, 22),(2, xiaoqiao, 123456, 小乔, 18),(3, diaochan, 123456, 貂蝉, 24),(4, lvbu, 123456, 吕布, 28),(5, zhaoyun, 12345678, 赵云, 27);
我们在maven工程中com.sde包下的子包 entity包创建一个User实体类
public class User {private Integer id;private String password;private String username;private String name;private Integer age;public User() {}public User(Integer id, String password, String username, String name, Integer age) {this.id id;this.password password;this.username username;this.name name;this.age age;}Overridepublic String toString() {return User{ id id , password password \ , username username \ , name name \ , age age };}
}
在创建一个测试类UpdateTest1 Testpublic void testJdbc() throws Exception {//注册驱动Class.forName(com.mysql.cj.jdbc.Driver);// 获取连接对象Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/sde01,root,root);//创建执行SQL的对象Statement statement connection.createStatement();//返回影响的行数int rows statement.executeUpdate(update user set password 666666 where id 1);System.out.println(rows 0 ? 修改成功 : 修改失败);//关闭资源statement.close();connection.close();}
}
结果 jdbc中的API详解 DriverManager 驱动管理器 注册驱动 获取数据库连接 DriverManager.registerDriver(...) 注册驱动的步骤 1当类加载Driver驱动类时会自动运行静态代码块中 2Class.forName这步操作可以省略 SPI机制Service Provider InterfaceJDK内置的一种服务提供发现机制可以轻松的扩展你得程序切换实现实现接口与实现类之间的解耦。 3 获取数据库连接DriverManager.getConnection(url,user,password); url:数据库连接的url 语法jdbc:mysql://ip地址(域名)/数据库名?参数键值对1参数键值对2。 说明如果连接的时是本机的默认端口的mysqlurl可以简写为jdbc:mysql:///数据库名?参数键值对... user:用户名 password数据库的密码 Connection Connection的作用获取执行SQL的对象 执行普通SQL对象Statementconnection.createStatement() 执行预编译SQL对象PreparedStatementconnection.preparedStatement() 可以通过PreparedStatement解决SQL注入问题 获取PreparedStatement对象设置参数值执行SQL Testpublic void testLogin() throws Exception {Connection connection PjdbcUtils.getConnection();String sql select * from user where username ? and password ?;PreparedStatement ps connection.prepareStatement(sql);ps.setString(1,xiaoqiao);ps.setString(2,123456);ResultSet resultSet ps.executeQuery();while (resultSet.next()){int id resultSet.getInt(id);String username resultSet.getString(username);String password resultSet.getString(password);String name resultSet.getString(name);int age resultSet.getInt(age);User user new User(id,username,password,name,age);System.out.println(user);}PjdbcUtils.close(connection,null,resultSet);} 效果 Statement statement的作用执行SQL 执行DDL、DML语句executeUpdate(sql) 如果是执行DML语句完毕返回值int代表DML语句影响的函数。 执行SQL语句executeQuery(sql) 返回值为ResultSet里面封装了查询结果。 执行增删改executeUpdate() 会返回一个int类型的数据表示影响的行数 执行查询时executeQuery() 会返回一个ResultSet的结果集 ResultSet ResultSet结果对象集封装了DQL查询语句查询的结果。 next( 将光标从当前位置向前移动一行并判断当前行是否是有效行返回值为boolean getXxxx()获取数据可以根据列的编号获取也可以根据列名获取推荐使用 ResultSet rs ps.executeQuery();while (rs.next()){int id rs.getInt(id);String username rs.getString(username);String password rs.getString(password);String name rs.getString(name);int age rs.getInt(age);System.out.println(new User(id,username,password,name,age));}PjdbcUtils.close(connection,ps,rs);} PreparedStatement 优势 1安全防SQL注入 2性能高 1获取PreparedStatement对象2设置参数值 3执行SQL 新建一个JDBC工具类PjdbcUtils类
public class PjdbcUtils {public static final String URL jdbc:mysql://localhost:3306/sde01; //改成你自己的数据库public static final String USER root; //改成你自己的用户名public static final String PASSWORD root; //改成你自己的密码public static Connection getConnection(){//加载驱动try {Class.forName(com.mysql.cj.jdbc.Driver);}catch (ClassNotFoundException e){e.printStackTrace();}//连接数据库Connection con null;try {con DriverManager.getConnection(URL,USER,PASSWORD);}catch (SQLException e){e.printStackTrace();}return con;}//关闭连接
public static void close(Connection con, Statement state, ResultSet rs) {if (rs ! null) {try {rs.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (state ! null) {try {state.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (con ! null) {try {con.close();} catch (SQLException throwables) {throwables.printStackTrace();}}}} 使用JDBC完成增删改查的案例 DisplayName(使用PreparedStatement完成增删改查)
public class PselectTest {/*** 测试查询功能* throws Exception*/TestDisplayName(测试查询功能)public void testLogin() throws Exception {Connection connection PjdbcUtils.getConnection();String sql select * from user where username ? and password ?;PreparedStatement ps connection.prepareStatement(sql);ps.setString(1,xiaoqiao);ps.setString(2,123456);ResultSet resultSet ps.executeQuery();while (resultSet.next()){int id resultSet.getInt(id);String username resultSet.getString(username);String password resultSet.getString(password);String name resultSet.getString(name);int age resultSet.getInt(age);User user new User(id,username,password,name,age);System.out.println(user);}PjdbcUtils.close(connection,null,resultSet);}/*** 测试删除功能* throws Exception*/TestDisplayName(测试删除功能)public void testDel() throws Exception {Connection connection PjdbcUtils.getConnection();String sql delete * from user where id ?;PreparedStatement ps connection.prepareStatement(sql);ps.setInt(1,6);ps.executeUpdate();PjdbcUtils.close(connection,ps,null);}TestDisplayName(测试修改功能)public void testUpdate() throws Exception {Connection connection PjdbcUtils.getConnection();String sql update user set username ?,password ?,name ?,age ? where id ?;PreparedStatement ps connection.prepareStatement(sql);ps.setString(1,sundaoen);ps.setString(2,121212);ps.setString(3,戴恩);ps.setInt(4,18);ps.setInt(5,6);int rows ps.executeUpdate();System.out.println(rows 0 ? 修改成功 : 修改失败);PjdbcUtils.close(connection,ps,null);}TestDisplayName(测试新增功能)public void testAdd() throws Exception {Connection connection PjdbcUtils.getConnection();String sql insert into user values(null,?,?,?,?);PreparedStatement ps connection.prepareStatement(sql);ps.setString(1,luban);ps.setString(2,666666);ps.setString(3,鲁班);ps.setInt(4,13);int rows ps.executeUpdate();System.out.println(rows 0 ? 添加成功 : 添加失败);PjdbcUtils.close(connection,ps,null);}
}
