MySQL_(Java)使用JDBC向数据库中删除(delete)数据
2023-09-14 08:57:05 时间
MySQL_(Java)使用JDBC向数据库发起查询请求 传送门
MySQL_(Java)使用JDBC向数据库中插入(insert)数据 传送门
MySQL_(Java)使用JDBC向数据库中删除(delete)数据 传送门
MySQL_(Java)使用JDBC向数据库中修改(update)数据 传送门
MySQL数据库中的数据,数据库名garysql,表名garytb,删除数据库id=2的数据
![](https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif)
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JDBC01 { public static void main(String[] args) throws SQLException { delete(2); } public static void selectAll() throws SQLException { //注册驱动 使用驱动连接数据库 Connection con = null; Statement stmt = null; ResultSet rs = null; try { //数据库的连接 con = JDBCUtils.getConnection(); //数据库的增删改查 stmt = con.createStatement(); //返回一个结果集 rs =stmt.executeQuery("select * from garytb"); while(rs.next()) { //System.out.println(rs.getString(1)+","+rs.getString(2)+","+rs.getString(3)); System.out.println(rs.getString("id")+","+rs.getString("username")+","+rs.getString("password")); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { JDBCUtils.close(rs, stmt, con); } } //校验用户 public static boolean selectByUernamePassword(String username,String password) throws SQLException { Connection con=null; Statement stmt = null; ResultSet rs = null; try { Class.forName("com.mysql.jdbc.Driver"); String url ="jdbc:mysql://localhost:3306/garysql?useUnicode=true&characterEncoding=UTF8&useSSL=false"; con = DriverManager.getConnection(url,"root","123456"); stmt =con.createStatement(); String sql = "select * from garytb where username = '"+username+"' and password = '"+password+"'"; //System.out.println(sql); rs = stmt.executeQuery(sql); if(rs.next()) { return true; }else { return false; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { if(rs!=null) rs.close(); if(stmt!=null) stmt.close(); if(con!=null) con.close(); } return false; } public static boolean selectByUP2(String username,String password) throws SQLException{ Connection con=null; Statement stmt = null; ResultSet rs = null; try { Class.forName("com.mysql.jdbc.Driver"); String url ="jdbc:mysql://localhost:3306/garysql?useUnicode=true&characterEncoding=UTF8&useSSL=false"; con = DriverManager.getConnection(url,"root","123456"); String sql = "select * from garytb where username = ? and password = ?"; PreparedStatement pstmt = con.prepareStatement(sql); //添加参数 pstmt.setString(1, username); pstmt.setString(2, password); //进行查询 rs = pstmt.executeQuery(); if(rs.next()) { return true; }else { return false; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { if(rs!=null) rs.close(); if(stmt!=null) stmt.close(); if(con!=null) con.close(); } return false; } //pageNumber是页数,第几页,pageCount是每页显示多少个数据 public static void selectUserByPage(int pageNumber,int pageCount) throws SQLException { //注册驱动 使用驱动连接数据库 Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { Class.forName("com.mysql.jdbc.Driver"); //String url ="jdbc:mysql://localhost:3306/garysql"; //指定编码查询数据库 String url ="jdbc:mysql://localhost:3306/garysql?useUnicode=true&characterEncoding=UTF8&useSSL=false"; String user = "root"; String password = "123456"; //建立和数据库的连接 con = DriverManager.getConnection(url,user,password); stmt = con.prepareStatement("select * from garytb limit ?,?"); stmt.setInt(1, (pageNumber-1)*pageCount ); stmt.setInt(2, pageCount); rs = stmt.executeQuery(); while(rs.next()) { //System.out.println(rs.getString(1)+","+rs.getString(2)+","+rs.getString(3)); System.out.println(rs.getString("id")+","+rs.getString("username")+","+rs.getString("password")); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { if(rs!=null) rs.close(); if(stmt!=null) stmt.close(); if(con!=null) con.close(); } } //crud: create read updata delete //插入语句 public static void insert(String username,String password) throws SQLException { //注册驱动 使用驱动连接数据库 Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = JDBCUtils.getConnection(); String sql = "insert into garytb(username,password) values(?,?)"; stmt = con.prepareStatement(sql); stmt.setString(1, username); stmt.setString(2, password); int result =stmt.executeUpdate();// 返回值代表收到影响的行数 System.out.println("插入成功"+username); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { JDBCUtils.close(rs, stmt, con); } } public static void delete(int id) throws SQLException { //注册驱动 使用驱动连接数据库 Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = JDBCUtils.getConnection(); String sql = "delete from garytb where id = ?"; stmt = con.prepareStatement(sql); stmt.setInt(1, id); int result =stmt.executeUpdate();// 返回值代表收到影响的行数 if(result>0) { System.out.println("删除成功"); }else { System.out.println("删除失败"); } } catch (Exception e) { e.printStackTrace(); } finally { JDBCUtils.close(rs, stmt, con); } } }
根据id删除数据库中的数据表
public static void delete(int id) throws SQLException { //注册驱动 使用驱动连接数据库 Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = JDBCUtils.getConnection(); String sql = "delete from garytb where id = ?"; stmt = con.prepareStatement(sql); stmt.setInt(1, id); int result =stmt.executeUpdate();// 返回值代表收到影响的行数 if(result>0) { System.out.println("删除成功"); }else { System.out.println("删除失败"); } } catch (Exception e) { e.printStackTrace(); } finally { JDBCUtils.close(rs, stmt, con); } }
相关文章
- Mysql远程连接数据库报错排查:pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on '**.**.**.**' (timed out)")
- Mysql:is not allowed to connect to this MySQL server
- 【C/C++学院】(23)Mysql数据库编程--C语言编程实现mysql客户端
- 【MySQL】Can't get stat of './mysql/slow_log.CSV' (Errcode: 2)
- 【MySql】mysql 表的常规管理
- Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
- XtraBackup出现 Can't connect to local MySQL server through socket '/tmp/mysql.sock'
- 【JAVA】 04-Java中的多线程
- PHP连接MySQL数据库的三种方式(mysql、mysqli、pdo)
- Can’t connect to local MySQL server through socket ‘/var/lib/mysql/mysql.sock’
- PHP连接MySQL数据库的三种方式(mysql、mysqli、pdo)--续
- MySQL事务隔离级别理解_解读MYSQL的可重复读、幻读及实现原理
- MySQL用户权限(Host,User,Password)管理(mysql.user)
- 当年的Java考试:JAVA&移动应用&大数据-大三-社区疫苗接种管理系统(全部源码·保姆式呵护)
- Java中new Date插入mysql数据库,数据库时间多一秒问题
- 解决Cause: java.sql.SQLException: sql injection violation, dbType mysql ... token IDENTIFIER deleted错误
- 解决idea出现的java.lang.OutOfMemoryError: Java heap space的问题
- tomcat链接mysql时超时报错java.io.EOFException: Can not read response from server. Expected to read 4 bytes,
- Java连接MySQL数据库
- MySQL Study之--Mysql无法启动“mysql.host”
- JAVA连接ACCESS、MYSQL、SQLSEVER、ORACLE数据库
- spring boot 连接mysql mongodb with jpa
- java 连接数据库mysql的方法
- Mysql之安全清理mysql-slow.log
- Mysql安装多台mysql
- 使用Java Spring消费MySQL中的数据库存储过程
- JAVA开发讲义(二)-Java程序设计之数据之谜一