Выполнение запроса с фабриками MySQL и Connector J
Я новичок в MySQL Fabrics и пытаюсь создать кластеры высокой доступности для собственного понимания. Я загрузил MySQL-Utilities 1.5.5 и python 27 для запуска фабрики. Ниже используется команда:
shell> python mysqlfabric.py управлять запуском
С помощью этой команды я смог убедиться, что сервер фабрики запущен и что он создал базу данных для хранения информации, связанной с фабрикой. Следующий вывод:
Теперь вместо использования соединения MySQL нам нужно использовать соединение Fabric для взаимодействия с сервером Fabric, который будет взаимодействовать с основным сервером (серверами, добавленными в группу) для выполнения операций MySQL. Ниже приведен пример кода:
import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;import java.sql.Statement;import com.mysql.fabric.jdbc.JDBC4FabricMySQLConnection;
public class fabrics {
JDBC4FabricMySQLConnection connection;
public static void main(String [] args) throws SQLException {
fabrics f = new fabrics();
f.connection = (JDBC4FabricMySQLConnection)DriverManager.getConnection("jdbc:mysql:fabric://"
+ "localhost:32274/employee?fabricUsername=admin&fabricPassword=tropos", "root", "tropos123");
f.connection.setServerGroupName("piyush");
f.connection.addQueryTable("employees");
PreparedStatement stmt = f.connection.prepareStatement("select * from employees");
stmt.executeQuery();
stmt.close();
f.connection.close();
}
}
Во время отладки я смог получить соединение, но при выполнении запроса ничего не происходит, значит, он никогда не возвращается, и я не вижу никаких исключений, поступающих на консоль; на сервере фабрики MySQL также ничего не происходит. Любой, кто застрял в этой ситуации, был бы очень полезен. Действительно, помощь будет высоко ценится.