JDK1.7下测试ConnectorJ连接MySQL8.0

打印 上一主题 下一主题

主题 1013|帖子 1013|积分 3039

马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。

您需要 登录 才可以下载或查看,没有账号?立即注册

x

  • GreatSQL社区原创内容未经授权不得随意使用,转载请联系小编并注明来源。
  • GreatSQL是MySQL的国产分支版本,使用上与MySQL一致。
  • 本文来源:社区原创投稿;作者:王庆勋。
客户的一些应用系统使用的JDK1.7版本,在将数据库迁移到MySQL8.0的过程中,发现有些MySQL connector/J的版本无法连接到MySQL8.0。本文描述了在Linux JDK1.7环境下,测试不同版本Connector/J的方法,也可用于为MySQL接口的国产数据库产品选择Connector/J版本。
MySQL Connector/J说明

MySQL通过MySQL Connector/J为用Java语言开发的客户端应用程序提供连接,MySQL Connector/J是一个实现Java数据库连接(JDBC) API的驱动程序。
MySQL Connector/J是一个JDBC 4型驱动程序。Type 4标志意味着驱动程序是MySQL协议的纯Java实现,不依赖于MySQL客户端库。
MySQL Connector/J有两个版本:

  • Connector/J 5.1是第4类纯Java JDBC驱动程序,符合JDBC 3.0、4.0、4.1和4.2规范。它提供了与MySQL所有功能的兼容性,包括5.6、5.7和8.0。Connector/J 5.1提供了易于开发的特性,包括向驱动程序管理器自动注册、标准化的有效性检查、分类的SQLExceptions、对大量更新计数的支持、对java.time包的本地和偏移日期时间变量的支持、对JDBC-4.x XML处理的支持、对每个连接客户端信息的支持以及对NCHAR、NVARCHAR和NCLOB数据类型的支持。
  • Connector/J 8.0是用于Java 8平台的第4类纯Java JDBC 4.2驱动程序。它提供了兼容MySQL 5.6、5.7和8.0的所有功能。强烈推荐MySQL连接器/J 8.0与MySQL服务器8.0、5.7和5.6一起使用。请升级到MySQL连接器/J 8.0。
Connector/J不同版本的JDBC、MySQL Server和Java的信息:
Connector/J 版本Driver Type实现的 JDBC 版本MySQLServer 版本支持的 JRE版本5.143.0, 4.0, 4.1, 4.25.6, 5.7, 8.01.5.x, 1.6.x, 1.7.x, 1.8.x8.044.25.6, 5.7, 8.01.8.x可知,要支持JRE1.7版本,需选用连接器Connector/J的版本为5.1 ,而5.1的最新版本为5.1.49  。
测试Connector/J 5.1的不同版本

安装配置jdk1.7

检查当前jdk版本
  1. [root@host73 ~]# java -version
  2. java version "1.8.0_111"
  3. Java(TM) SE Runtime Environment (build 1.8.0_111-b14)
  4. Java HotSpot(TM) 64-Bit Server VM (build 25.111-b14, mixed mode)
  5. [root@host73 ~]# javac -version
  6. javac 1.8.0_111
复制代码
安装jdk1.7
  1. yum install -y java-1.7.0-openjdk.x86_64 java-1.7.0-openjdk-devel.x86_64
复制代码
修改JAVA_HOME

修改/etc/profile文件:

export JAVA_HOME=/usr/lib/jdk1.8.0_111
改为:

export JAVA_HOME=/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.261-2.6.22.2.el7_8.x86_64
重新登录,检查java版本
  1. [root@host73 ~]# which java
  2. /usr/lib/jvm/java-1.7.0-openjdk-1.7.0.261-2.6.22.2.el7_8.x86_64/bin/java
  3. [root@host73 ~]# which javac
  4. /usr/lib/jvm/java-1.7.0-openjdk-1.7.0.261-2.6.22.2.el7_8.x86_64/bin/javac
  5. [root@host74 java]# java -version
  6. java version "1.7.0_261"
  7. OpenJDK Runtime Environment (rhel-2.6.22.2.el7_8-x86_64 u261-b02)
  8. OpenJDK 64-Bit Server VM (build 24.261-b02, mixed mode)
  9. [root@host74 java]# javac -version
  10. javac 1.7.0_261
复制代码
构造测试数据

确认MySQL数据库版本
  1. mysqld --version
  2. /usr/local/mysql-8.0.26-linux-glibc2.17-x86_64-minimal-rebuild/bin/mysqld  Ver 8.0.26 for Linux on x86_64 (MySQL Community Server - GPL)
复制代码
创建表及用户**
  1. create database testdb;
  2. create user testuser identified with mysql_native_password by 'testpass';
  3. grant all on testdb.* to testuser;
  4. use testdb;
  5. CREATE TABLE `dbinfo` (
  6.   `id` int(11) NOT NULL AUTO_INCREMENT,
  7.   `name` char(20) NOT NULL DEFAULT '' COMMENT 'dbinfo',
  8.   `website` varchar(255) NOT NULL DEFAULT 'website',
  9.   `opensource` varchar(2) NOT NULL DEFAULT '0' COMMENT 'is opensource',
  10.   `country` char(10) NOT NULL DEFAULT '' COMMENT 'country',
  11.   PRIMARY KEY (`id`)
  12. ) ENGINE=InnoDB ;
  13. insert into dbinfo values('1','Oracle','www.oracle.com','否','美国');
  14. insert into dbinfo values('2','MySQL','www.mysql.com','是','美国');
  15. insert into dbinfo values('3','GreatSQL','www.greatsql.com','是','中国');
复制代码
编写测试用java程序

编写ShowDbinfo.java程序,用于测试连接MySQL数据库。
  1. import java.sql.*;
  2. public class ShowDbinfo {
  3.     // MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
  4.     static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
  5.     static final String DB_URL = "jdbc:mysql://172.17.128.73:16315/testdb?useSSL=false";
  6.     // MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
  7.     //static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";  
  8.     //static final String DB_URL = "jdbc:mysql://172.17.128.73:16310/testdb?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
  9.     // 数据库的用户名与密码,需要根据自己的设置
  10.     static final String USER = "testuser";
  11.     static final String PASS = "testpass";
  12.     public static void main(String[] args) {
  13.         Connection conn = null;
  14.         Statement stmt = null;
  15.         try{
  16.             // 注册 JDBC 驱动
  17.             Class.forName(JDBC_DRIVER);
  18.             // 打开链接
  19.             System.out.println("开始连接数据库...");
  20.             conn = DriverManager.getConnection(DB_URL,USER,PASS);
  21.             // 执行查询
  22.             stmt = conn.createStatement();
  23.             String sql;
  24.             sql = "SELECT id, name, website,opensource,country FROM dbinfo";
  25.             ResultSet rs = stmt.executeQuery(sql);
  26.             // 展开结果集数据库
  27.             while(rs.next()){
  28.                 // 通过字段检索
  29.                 int id  = rs.getInt("id");
  30.                 String name = rs.getString("name");
  31.                 String website = rs.getString("website");
  32.                 String opensource = rs.getString("opensource");
  33.                 String country = rs.getString("country");
  34.                 // 输出数据
  35.                 System.out.print("ID: " + id);
  36.                 System.out.print(", 名称: " + name);
  37.                 System.out.print(", website: " + website);
  38.                 System.out.print(", 开源: " + opensource);
  39.                 System.out.print(", 来自: " + country);
  40.                 System.out.print("\n");
  41.             }
  42.             // 完成后关闭
  43.             rs.close();
  44.             stmt.close();
  45.             conn.close();
  46.         }catch(SQLException se){
  47.             se.printStackTrace();
  48.         }catch(Exception e){
  49.             e.printStackTrace();
  50.         }finally{
  51.             try{
  52.                 if(stmt!=null) stmt.close();
  53.             }catch(SQLException se2){
  54.             }
  55.             try{
  56.                 if(conn!=null) conn.close();
  57.             }catch(SQLException se){
  58.                 se.printStackTrace();
  59.             }
  60.         }
  61.         System.out.println("Goodbye!");
  62.     }
  63. }
复制代码
运行java程序测试

编译运行java程序,测试指定版本的连接器是否可以连接数据库。以版本5.1.46为例说明。
获取Connector/J

从MySQL官方https://downloads.mysql.com/archives/c-j/下载5.1.46版本的Connector/J,上传解压后,将mysql-connector-java-5.1.46.jar拷贝到ShowDbinfo.java所在目录。
编译运行测试程序

编译java源程序:
  1. javac -cp .:mysql-connector-java-5.1.46.jar ShowDbinfo.java
复制代码
运行java程序连接数据库:
  1. java -cp .:mysql-connector-java-5.1.46.jar ShowDbinfo
复制代码
输出结果如下:
  1. 开始连接数据库...
  2. ID: 1, 名称: Oracle, website: www.oracle.com, 开源: 否, 来自: 美国
  3. ID: 2, 名称: MySQL, website: www.mysql.com, 开源: 是, 来自: 美国
  4. ID: 3, 名称: GreatSQL, website: www.greatsql.com, 开源: 是, 来自: 中国
  5. Goodbye!
复制代码
连接失败connector/J

下载测试了5.1的几个版本,结果如下表:
驱动版本是否可以连接MySQL8.05.1.49是5.1.46是5.1.40否5.1.30是5.1.6是5.1.40无法连接MySQL8.0,报错信息如下:
  1. 开始连接数据库...
  2. java.sql.SQLException: Unknown system variable 'query_cache_size'
  3. at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:964)
  4. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3970)
  5. at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3906)
  6. at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2524)
  7. at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2677)
  8. at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2545)
  9. at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2503)
  10. at com.mysql.jdbc.StatementImpl.executeQuery(StatementImpl.java:1369)
  11. at com.mysql.jdbc.ConnectionImpl.loadServerVariables(ConnectionImpl.java:3833)
  12. at com.mysql.jdbc.ConnectionImpl.initializePropsFromServer(ConnectionImpl.java:3283)
  13. at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2297)
  14. at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2083)
  15. at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:806)
  16. at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47)
  17. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
  18. at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
  19. at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
  20. at java.lang.reflect.Constructor.newInstance(Constructor.java:527)
  21. at com.mysql.jdbc.Util.handleNewInstance(Util.java:425)
  22. at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:410)
  23. at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:328)
  24. at java.sql.DriverManager.getConnection(DriverManager.java:571)
  25. at java.sql.DriverManager.getConnection(DriverManager.java:215)
  26. at ShowDbinfo.main(ShowDbinfo.java:27)
  27. Goodbye!
复制代码
Enjoy GreatSQL
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

民工心事

论坛元老
这个人很懒什么都没写!
快速回复 返回顶部 返回列表