怎么使用MySQL进行JDBC编程与增删改查

怎么使用MySQL进行JDBC编程与增删改查

Java的数据库编程JDBC

概念

JDBC是一种用于执行sql语句的Java API，他是java中的数据库连接规范，这个API由一些接口和类组成。它提供了一个标准的API，使得Java开发人员可以统一访问多种关系数据库本质是通过代码自己实现一个MySQL客户端，通过网络和服务器进行数据的交互，客户端不能凭空出现，所以数据库提供了一组API方便我们实现数据库的种类有很多，不同的数据库提供的API不太一样，所以java为了解决这一问题提供了JDBC，java自带的一种数据库操作API，这种API覆盖所有数据库操作的操作方式本质上是java自身完成了JDBC API和数据库API之间进行转换

使用步骤

创建DataSource对象，这个对象就描述了数据库服务器在哪

DataSource dataSource = new MysqlDataSource(); //设置数据库所在的地址 ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/lmp?characterEncoding=utf8&useSSL=false"); //设置登录数据库的用户名 ((MysqlDataSource)dataSource).setUser("root"); //设置登录数据库的密码 ((MysqlDataSource)dataSource).setPassword("woshizhu123");登录后复制

通过Connection连接数据库(输入密码连接成功)

//import java.sql.Connection; Connection connection = dataSource.getConnection();登录后复制

拼接sql语句(写入sql语句)

String sql = "insert into student values(1,'张三')";登录后复制

将sql语句包装成对象

PreparedStatement statement = connection.prepareStatement(sql);登录后复制

执行sql语句(按下回车执行sql语句)

int ret = statement.executeUpdate();登录后复制

执行 update delete insert 使用 executeUpdate() 方法执行 select 使用 executeQuery() 方法使用 executeQuery() 方法 会返回一个resultSet集合, 包含查找到的数据, 初始情况下resultSet不指向任一行记录, 使用next,让他指向第一条记录, 再使用next指向下一条记录

释放资源

statement.close(); connection.close();登录后复制

利用JDBC实现增加(insert)

public class TestJDBC { public static void main(String[] args) throws SQLException { Scanner scanner = new Scanner(System.in); DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf-8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); System.out.println("输入id"); int id = scanner.nextInt(); System.out.println("输入名字"); String name = scanner.next(); String sql = "insert into student values(?,?)"; PreparedStatement statement = connection.prepareStatement(sql); statement.setInt(1,id); statement.setString(2,name); int ret = statement.executeUpdate(); if(ret == 1){ System.out.println("插入成功"); }else { System.out.println("插入失败"); } statement.close(); connection.close(); }}登录后复制

利用JDBC实现删除(delete)

public class TestJDBCDelete{ public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); Scanner scanner = new Scanner(System.in); System.out.println("请输入要删除的id"); int id = scanner.nextInt(); String sql = "delete from student where id = ?"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setInt(1,id); int ret = preparedStatement.executeUpdate(); System.out.println(ret); preparedStatement.close(); connection.close(); }登录后复制

利用JDBC实现修改(update)

public class TestJDBCUpdate { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); Scanner scanner = new Scanner(System.in); System.out.println("请输入要修改的学生id"); int id = scanner.nextInt(); System.out.println("请输入要修改的学生姓名"); String name = scanner.next(); String sql = "update student set name = ? where id = ?"; PreparedStatement statement = connection.prepareStatement(sql); statement.setString(1,name); statement.setInt(2,id); int ret = statement.executeUpdate(); System.out.println(ret); statement.close(); connection.close(); }}登录后复制

利用JDBC实现查找(select)

public static void testJDBCSelect() throws SQLException { //1创建DataSource对象 DataSource dataSource = new MysqlDataSource(); //2连接数据库 ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java_5_31?characterEncoding=utf-8&useSSL=true"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("listen"); Connection connection = dataSource.getConnection(); //3拼接sql String sql = "select * from student"; PreparedStatement statement = connection.prepareStatement(sql); //4执行sql ResultSet resultSet = statement.executeQuery(); //5遍历得到的集合 while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("name"); int classId = resultSet.getInt("classId"); System.out.println("id " + id + " name " + name + " classId " + classId); } //6关闭资源 resultSet.close(); statement.close(); connection.close(); }登录后复制

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。