MySQL_(Java)使用JDBC向数据库中删除(delete)数据

25-02-03 19

对于想了解MySQL_(Java)使用JDBC向数据库中删除(delete)数据的读者，本文将是一篇不可错过的文章，并且为您提供关于IDEA使用JDBC连接MySQL数据库详细教程、IDEA使用JDB

对于想了解MySQL_(Java)使用JDBC向数据库中删除(delete)数据的读者，本文将是一篇不可错过的文章，并且为您提供关于IDEA使用JDBC连接MySQL数据库详细教程、IDEA使用JDBC连接数据库（MySQL）、Java JDBC - 如何使用JDBC驱动程序通过代理连接到MySQL、Java JDBC 连接 MySQL8 数据库的有价值信息。

本文目录一览：

MySQL_(Java)使用JDBC向数据库中删除(delete)数据
IDEA使用JDBC连接MySQL数据库详细教程
IDEA使用JDBC连接数据库（MySQL）
Java JDBC - 如何使用JDBC驱动程序通过代理连接到MySQL
Java JDBC 连接 MySQL8 数据库

MySQL_(Java)使用JDBC向数据库中删除(delete)数据

　　MySQL_(Java)使用JDBC向数据库发起查询请求　　传送门

　　MySQL_(Java)使用JDBC向数据库中插入(insert)数据　　传送门

　　MySQL_(Java)使用JDBC向数据库中删除(delete)数据　　传送门

　　MySQL_(Java)使用JDBC向数据库中修改(update)数据　　传送门

　　MySQL数据库中的数据，数据库名garysql，表名garytb，删除数据库id=2的数据

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);
        }
    }
}

JDBC01.java

　　根据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);
        }
    }

IDEA使用JDBC连接MySQL数据库详细教程

一、下载MySQL数据库并进行安装和配置

二、下载JDBC

下载地址：https://dev.mysql.com/downloads/connector/j/5.1.html

三、创建java项目，导入.jar包

四、测试访问数据库

1.使用JDBC API 连接和访问数据库，一般分为以下5个步骤

(1)加载驱动程序

(2)建立连接对象

(3)创建语句对象

(4)获得SQL语句的执行结果

(5)关闭建立的对象，释放资源

2.例如下面访问数据库的代码

（1）首先使用Navicat连接MySQL数据库，并在localhost新建如下图所示的数据库和表

特别注意

（2）在IDEA中新建类，并编写如下的程序

import java.sql.*;

public class MySQLDemo {
    public static void main(String[] args) throws Exception{
        //加载数据库驱动程序
        try{
            Class.forName("com.mysql.cj.jdbc.Driver");
        }catch (ClassNotFoundException cne){
            cne.printStackTrace();
        }
        String dburl = "jdbc:mysql://127.0.0.1:3306/webstore?&useSSL=false&serverTimezone=UTC";
        String sql = "SELECT * FROM products where id < 104";
        try(    Connection conn = DriverManager.getConnection(dburl,"root","123456");
            Statement stmt = conn.createStatement();
            ResultSet rst = stmt.executeQuery(sql))

        {
            while (rst.next()){
                System.out.println(rst.getInt(1)+"\t"+
                        rst.getString(2)+"\t"+rst.getString(3)+
                        "\t"+rst.getFloat(4) + "\t" + rst.getInt(5)
                        );
            }

        }catch (SQLException se){
            se.printStackTrace();
        }

    }
}

（3）运行结果如下图所示

IDEA使用JDBC连接数据库（MySQL）

简略步骤

一.软件准备

IDEA，Navicat for MySQL,JDBC安装
JDBC安装地址：(https://dev.mysql.com/downloads/connector/j/5.1.html)

二.MySQL准备

首先启动数据库，建立一个新的连接。可以建立一个表格，方便后面代码实现。
在这里插入图片描述
webstore为数据库名字

三.IDEA部分

1.新建项目
在这里插入图片描述

在这里插入图片描述
2.导入jar包

3.编写相应代码


package com.dgd.test;

import java.sql.*;

/**
 * @author JWH
 * @create 2019-08-30
 * 测试数据库
 */
public class Test {
    public static void main(String[] args) throws Exception{
        //加载数据库驱动程序
        try{
            Class.forName("com.mysql.cj.jdbc.Driver");
        }catch (ClassNotFoundException cne){
            cne.printStackTrace();
        }
        String dburl = "jdbc:mysql://127.0.0.1:3306/webstore?&useSSL=false&serverTimezone=UTC";  //webstore代表数据库名称
        String sql = "SELECT * FROM products where id < 104";
        try(    Connection conn = DriverManager.getConnection(dburl,"root","123456");
                Statement stmt = conn.createStatement();
                ResultSet rst = stmt.executeQuery(sql))

        {
            while (rst.next()){
                System.out.println(rst.getInt(1)+"\t"+
                        rst.getString(2)+"\t"+rst.getString(3)+
                        "\t"+rst.getFloat(4) + "\t" + rst.getInt(5)
                );
            }

        }catch (SQLException se){
            se.printStackTrace();
        }

    }
}

4.运行代码
结果如下：
在这里插入图片描述

Java JDBC - 如何使用JDBC驱动程序通过代理连接到MySQL

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

public class Main {
  public static void main(String[] args) throws Exception{
    Class.forName("com.mysql.jdbc.Driver");
    Connection conn = null;
    Properties info = new Properties();
    // info.put("proxy_type", "4"); // SSL Tunneling
    info.put("proxy_host", "[proxy host]");
    info.put("proxy_port", "[proxy port]");
    info.put("proxy_user", "[proxy user]");
    info.put("proxy_password", "[proxy password]");
    info.put("user", "[db user]");
    info.put("password", "[db pass word]");
    conn = DriverManager.getConnection("jdbc:mysql://[db host]/", info);

    Statement stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery("Select NOW()");
    rs.next();
    System.out.println("Data- " + rs.getString(1));
    rs.close();
    stmt.close();
    conn.close();
  }
}

Java JDBC 连接 MySQL8 数据库

MySQL 8.0 以上版本的数据库连接有所不同：

1、MySQL 8.0 以上版本驱动包版本 mysql-connector-java-8.0.16.jar。
2、com.mysql.jdbc.Driver 更换为 com.mysql.cj.jdbc.Driver。
MySQL 8.0 以上版本不需要建立 SSL 连接的，需要显示关闭。
allowPublicKeyRetrieval=true 允许客户端从服务器获取公钥。
最后还需要设置 CST。

加载驱动与连接数据库方式如下：

Class.forName("com.mysql.cj.jdbc.Driver");conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_demo?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC","root","password");

package com.runoob.test; import java.sql.*;//java项目www.fhadmin.orgpublic class MySQLDemo {  // MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB";  // MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL //static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";  //static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";  // 数据库的用户名与密码，需要根据自己的设置 static final String USER = "root"; static final String PASS = "123456";  public static void main(String[] args) {  Connection conn = null;  Statement stmt = null;  try{   // 注册 JDB

关于MySQL_(Java)使用JDBC向数据库中删除(delete)数据的介绍已经告一段落，感谢您的耐心阅读，如果想了解更多关于IDEA使用JDBC连接MySQL数据库详细教程、IDEA使用JDBC连接数据库（MySQL）、Java JDBC - 如何使用JDBC驱动程序通过代理连接到MySQL、Java JDBC 连接 MySQL8 数据库的相关信息，请在本站寻找。

本文标签：