请问用java 如何连接 mysql fabric

大佳 发布于 2014/09/12 14:53
阅读 2K+
收藏 0

@AnthonyYau 你好,想跟你请教个问题:请问用java 如何连接 mysql fabric ,Oracle官方给出的demo无法实现。

我的环境是:

共有3台PC机(采用Oracle Linux 7.0 64位版本):

一台Fabric Manager,ip=10.1.1.141,端口32274,管理用户名是admin,密码是admin,建立了一个

组:my_group

一台主服务器,ip=10.1.1.142,mysql数据库实例是3306,用户名是root,密码123456

一台从服务器,ip=10.1.1.190,mysql数据库实例是3306,用户名是root,密码123456

目前,利用mysql客户端均能访问主从服务器,但在Intellij 12.0开发环境下,用connector/j 5.1.32无法

访问数据库,错误提示是:Unknown protocol version: 0

        String hostname = "10.1.1.141";
        String port = "32274";
        String user = "root";   //MySQL数据库的user
        String password = "123456";  //MySQL数据库的password
        String fabricUsername ="admin";   //fabric管理服务的User
        String fabricPassword ="admin";    //fabric管理服务的Password

        Connection rawConnection = DriverManager.getConnection(
                "jdbc:mysql:fabric://" + hostname + ":" + Integer.valueOf(port) +
                "/mysql?fabricServerGroup=my_group" +
                      "&fabricUsername=" + fabricUsername +
                      "&fabricPassword=" + fabricPassword,
                user, password);


上面一条语句报错:Caused by: com.mysql.fabric.FabricCommunicationException: Unknown protocol version: 0

能帮我看看这是什么原因吗,如何在java里连接mysql fabric,希望能提供帮助,不胜感激!

heshansky

email:lisj@ecpark.cn

qq:368409858


加载中
0
m
melnnyy

如果你用的是mysql-utilities-1.4.4,那么请把connector/j的版本降到5.1.31就可以了!

0
米多
米多

引用来自“melnnyy”的评论

如果你用的是mysql-utilities-1.4.4,那么请把connector/j的版本降到5.1.31就可以了!

Connection rawConnection = DriverManager.getConnection(
                "jdbc:mysql:fabric://" + hostname + ":" + Integer.valueOf(port) +
                        "/ajianzheng?fabricServerGroup=my_group" +
                        "&fabricUsername=" + fabricUsername +
                        "&fabricPassword=" + fabricPassword,
                user, password);

        // 1. Create database and table for our demo
        Statement statement = rawConnection.createStatement();  // 程序卡在这里执行不下去
        statement.executeUpdate("INSERT INTO TABLE test VALUES ('midoo');");
        statement.close();
        rawConnection.close();

请问下我的程序卡在 

Statement statement = rawConnection.createStatement();

执行不下去,怎么搞?



返回顶部
顶部