Java连接MySQL数据库 JBDC接口实现增删查改 mysql connector

25-04-25 4

想了解Java连接MySQL数据库JBDC接口实现增删查改mysqlconnector的新动态吗？本文将为您提供详细的信息，此外，我们还将为您介绍关于8、PythonMySQL-mysql-conne

想了解Java连接MySQL数据库 JBDC接口实现增删查改 mysql connector的新动态吗？本文将为您提供详细的信息，此外，我们还将为您介绍关于8、Python MySQL - mysql-connector 驱动、Debezium MySQL Source Connector 是否支持 mysql ldap 可插拔认证、io.debezium.connector.mysql #connector æ��ä»¶, available connectors失败了??、java连接MySql数据库的新知识。

本文目录一览：

Java连接MySQL数据库 JBDC接口实现增删查改 mysql connector
8、Python MySQL - mysql-connector 驱动
Debezium MySQL Source Connector 是否支持 mysql ldap 可插拔认证
io.debezium.connector.mysql #connector æ��ä»¶, available connectors失败了??
java连接MySql数据库

Java连接MySQL数据库 JBDC接口实现增删查改 mysql connector

###1.准备MySQL驱动jar包 ### 可以去官网下载这里就不说了 ###2.把驱动jar包引入idea工程###

第一步点击idea右上角这个图标

第二部点击加号选择java

第三部选择驱动jar地址然后一直点击ok

驱动jar就被导入external libraries了

###3.增删查改的代码### 这里使用的表 create table EMP ( EMP_ID int(10) not null auto_increment, ENAME varchar(50), GENDER int(2) comment ''1男，2女'', HIREDATE date, primary key (EMP_ID) );

import java.sql.*;

public class JDBCDemo {
    //准备连接数据库的四大要素 （驱动 url 用户名 密码）Driver是驱动jar包里的一个类 mydb是本地创建的一个数据库 密码root是自己改的，请输入自己的密码
    private static final String DRIVER = "com.mysql.jdbc.Driver";
    private static final String URL = "jdbc:mysql://localhost:3306/mydb";
    private static final String USERNAME = "root";
    private static final String PASSWORD = "root";

    //增加数据
    public static void insert(){
        //准备sql语句
        String sql = "INSERT into emp(emp_id, ename, gender, hiredate) VALUES(null,''zhangsan'',1,''1999-12-12'')";
        //这两个对象是需要关闭的 先设为null 方便在finally块中关闭
        Connection connection = null;
        Statement statement = null;

        try {
            //加载驱动
            Class.forName(DRIVER);
            //获得数据库的连接对象
            connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
            //获得一个执行SQL的对象
            statement = connection.createStatement();
            //使用这个对象来执行SQL
            int i = statement.executeUpdate(sql);

            System.out.println("插入完毕"+i+"条");

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(statement != null){
                    statement.close();
                }
                if(connection != null){
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    //改数据
    public static void update(){
        //准备sql更改语句
        String sql = "update emp t set t.ename = ''李四'',t.gender = 2, t.HIREDATE = ''2019-12-12'' where t.EMP_ID = 4";

        Connection connection = null;
        Statement statement = null;

        try {
            //加载驱动
            Class.forName(DRIVER);
            //获得数据库的连接对象
            connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
            //获得一个执行SQL的对象
            statement = connection.createStatement();
            //使用这个对象来执行SQL
            int i = statement.executeUpdate(sql);

            System.out.println("修改完毕"+i+"条");

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(statement != null){
                    statement.close();
                }
                if(connection != null){
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    //删数据
    public static void delete(){
        //准备sql删除语句
        String sql = "delete from emp where emp_id = 2;";

        Connection connection = null;
        Statement statement = null;

        try {
            //加载驱动
            Class.forName(DRIVER);
            //获得数据库的连接对象
            connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
            //获得一个执行SQL的对象
            statement = connection.createStatement();
            //使用这个对象来执行SQL
            int i = statement.executeUpdate(sql);

            System.out.println("修改完毕"+i+"条");

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(statement != null){
                    statement.close();
                }
                if(connection != null){
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    //查数据
    public static void select(){
        //准备sql查找语句
        String sql = "select * from emp";
        Connection connection = null;
        Statement statement = null;
        ResultSet rs = null;

        try {
            //加载驱动
            Class.forName(DRIVER);
            //获得数据库的连接对象
            connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
            //获得一个执行SQL的对象
            statement = connection.createStatement();
            //执行查询的逻辑
            rs = statement.executeQuery(sql);
            //拿出数据
           while(rs.next()){
               //可以用数字代表列
               /*int empId = rs.getInt(1);
               String ename = rs.getString(2);
               int gender = rs.getInt(3);
               Date date = rs.getDate(4);*/
               //也可以用列的字段名
               int empId = rs.getInt("emp_id");
               String ename = rs.getString("ename");
               int gender = rs.getInt("gender");
               Date date = rs.getDate("hiredate");

               System.out.println(empId+"   "+ename+"   "+gender+"   "+date);
           }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            try {
                if(rs != null){
                    rs.close();
                }
                if(statement != null){
                    statement.close();
                }
                if(connection != null){
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }


    public static void main(String[] args) {
        //select示范
        select();
    }
}

###4.查找运行结果###

8、Python MySQL - mysql-connector 驱动

一、在线安装 mysql-connector ： pip install mysql-connector-python

二、操作流程

　　1、连接数据库信息： conn = mysql.connector.connect (**config)

　　数据库地址、端口、用户名、密码、数据库名 --》根据配置文件读取数据库连接信息

　　2、创建游标：cursor = conn.cursor ()

　　3、利用游标执行操作：cursor.execute (sql)

　　重点说明：

　　1）、增、删、改操作时：需要执行 conn.commit () 操作。 --》数据有更新，需要重新提交

　　2）、在 SQL 中的占位符，统一写 % s, 具体的类型，是在 tuple 中，传入的参数元素类型决定

　　4、获取查询数据：res = cursor.fetchall () 利用 cursor.fetchall () --》获取多条数据

　　5、关闭游标、关闭连接：cursor.close () conn.close ()

Debezium MySQL Source Connector 是否支持 mysql ldap 可插拔认证

如何解决Debezium MySQL Source Connector 是否支持 mysql ldap 可插拔认证？

Debezium MysqL Source Connector 是否支持 MysqL ldap 可插拔认证？

https://dev.mysql.com/doc/refman/8.0/en/ldap-pluggable-authentication.html

解决方法

在 gitter 上从 Debezium 用户组得到答案

Jiri Pechanec 07:14 @ranlupovich 嗨，不，它不受支持，因为用于处理 binlog 的库不支持它

io.debezium.connector.mysql #connector æ��ä»¶, available connectors失败了??

io.debezium.connector.mysql.MySqlConnector #connector æ��ä»¶, available connectors失败了??

Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.MySqlConnector #connector æ��ä»¶,

java连接MySql数据库

package Dao;

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 MySql {

private String url = "jdbc:mysql://localhost:3306/jw?useUnicode=true&characterEncoding=utf-8";
private String user = "root";
private String password = "root";
public Connection getCon(){
Connection conn = null;
try{
Connection con = DriverManager.getConnection(url , user , password ) ;
}catch(SQLException se){
System.out.println("数据库连接失败！");
se.printStackTrace() ;
}
return conn;
}
public void Query(String sql){
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
//建立数据库连接
conn =getCon();
stmt = conn.createStatement();//创建一个Statement对象
System.out.println("成功连接到数据库~");

/*在询数据表时，需要用到ResultSet接口，它类似于一个数据表，通过该接口的实例
* 可以获得检索结果集，以及对应数据表的接口信息。*/
rs = stmt.executeQuery(sql);//创建数据对象

//遍历查询的结果集
while (rs.next()) {
System.out.print(rs.getInt(1)+"\t");
System.out.print(rs.getString(2)+"\t");
System.out.print(rs.getString(3)+"\t");
System.out.print(rs.getString(4)+"\t");
System.out.println();
}
//关闭连接
rs.close();
stmt.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
public void insert(String sql){
Connection conn = null;
PreparedStatement pstm = null;
ResultSet rt = null;
Statement stmt = null;
//建立数据库连接
try {
conn =getCon();
//String sql = "INSERT INTO comments(MovieName,Mid,Mnum,url,content,date,star,usefulnum) VALUES(?,?,?,?,?,?,?,?)";
//pstm.setString(1, n.getMovieName());
//pstm.setString(2, n.getMid());
pstm = conn.prepareStatement(sql);
pstm.executeUpdate();

String sql3 = "select * from users";//要执行的SQL

/*在询数据表时，需要用到ResultSet接口，它类似于一个数据表，通过该接口的实例
* 可以获得检索结果集，以及对应数据表的接口信息。*/
ResultSet rs = stmt.executeQuery(sql3);//创建数据对象

System.out.println("编号"+"\t"+"姓名"+"\t"+"密码"+"\t"+"邮箱");
//遍历查询的结果集
while (rs.next()) {
System.out.print(rs.getInt(1)+"\t");
System.out.print(rs.getString(2)+"\t");
System.out.print(rs.getString(3)+"\t");
System.out.print(rs.getString(4)+"\t");
System.out.println();
}
//关闭连接
rs.close();
stmt.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
public void Delete(String sql){
Connection conn = null;
PreparedStatement psql = null;
//建立数据库连接
try {
conn =getCon();
psql = conn.prepareStatement(sql);
psql.executeUpdate();
psql.close();
}catch(SQLException e){
e.printStackTrace();
}catch (Exception e) {
e.printStackTrace();
}finally{
System.out.println("数据库数据删除成功！"+"\n");
}
}

}

今天关于Java连接MySQL数据库 JBDC接口实现增删查改 mysql connector的讲解已经结束，谢谢您的阅读，如果想了解更多关于8、Python MySQL - mysql-connector 驱动、Debezium MySQL Source Connector 是否支持 mysql ldap 可插拔认证、io.debezium.connector.mysql #connector æ��ä»¶, available connectors失败了??、java连接MySql数据库的相关知识，请在本站搜索。

本文标签：