MariaDB [(none)]> drop database test;
Query OK, 0 rows affected (0.01 sec)
 
MariaDB [(none)]> create database test character set=utf8 collate=utf8_general_ci;
Query OK, 1 row affected (0.00 sec)
mysql> use test
Database changed
MariaDB [test]> CREATE TABLE test1(id int, descr varchar(50), primary key (id));
Query OK, 0 rows affected (0.08 sec)
 
MariaDB [test]> insert into test.test1 values(1,1);
Query OK, 1 row affected (0.00 sec)

package jdbcdemo2;
 
import com.mysql.jdbc.Driver;
import com.mysql.jdbc.jmx.LoadBalanceConnectionGroupManager;
 
import java.sql.ResultSet;
import java.util.Properties;
import java.sql.Connection;
import java.sql.SQLException;
 
public class jdbcdemo2 {
  public static void main(String[] args) throws Exception {
    Driver driver = new Driver();
    Properties props = new Properties();
    ResultSet rs;
    LoadBalanceConnectionGroupManager jmx1 = new LoadBalanceConnectionGroupManager();
    String variable_value;
    Connection conn = null;
    int count;
    String JDBC_URL = "jdbc:mysql:loadbalance://192.168.56.101:3316,192.168.56.102:3316";
 
    props.put("loadBalanceConnectionGroup","galera_cluster01");
    props.put("loadBalanceEnableJMX","true");
 
    props.put("user", "yjaquier");
    props.put("password", "secure_password");
 
    System.out.println("\n------------ MySQL Connector/J and MySQL Load Balance Testing ------------\n");
 
    try {
    	Class.forName("com.mysql.jdbc.Driver");
    	}
    catch (ClassNotFoundException e) {
		  System.out.println("Where is your MySQL JDBC Driver?");
		  e.printStackTrace();
		  return;
	  }
 
    System.out.println("MySQL Connector/J driver loaded");
 
    System.out.println("Trying connection...");
 
    try {
    	conn = driver.connect(JDBC_URL, props);
    	conn.setAutoCommit(false);
		}
    catch (SQLException e) {
    	System.out.println("Connection Failed! Check output console");
    	e.printStackTrace();
    	return;
    	}
 
    System.out.println("Connection established...");
 
    System.out.println("Number of servers in cluster: "+jmx1.getActiveHostCount("galera_cluster01"));
    System.out.println("Server names(s) in cluster: "+jmx1.getActiveHostsList("galera_cluster01"));
 
    for(int i=1; i <= 1000; i++) {
    	System.out.println("\nQuery "+i+": ");
	try {
		rs = conn.createStatement().executeQuery("SELECT variable_value FROM information_schema.global_variables where variable_name='hostname'");
			}
		catch (SQLException e) {
			System.out.println("Select has failed...");
			System.out.println("Error cause: "+e.getCause());
			System.out.println("Error message: "+e.getMessage());
			continue;
		}
		while (rs.next()) {
			variable_value = rs.getString("variable_value");
			System.out.println("Working on node : " + variable_value);
		}
		rs.close();
 
		System.out.println("Inserting in test table...");
		try {
			count = conn.createStatement().executeUpdate("insert into test.test1 select max(id)+1,max(id)+1 from test.test1");
		}
		catch (SQLException e) {
			System.out.println("Insert has failed...");
			System.out.println("Error cause: "+e.getCause());
			System.out.println("Error message: "+e.getMessage());
			continue;
		}
 
		try {
			conn.commit();
		}
		catch (SQLException e) {
			System.out.println("Error cause: "+e.getCause());
			System.out.println("Error message: "+e.getMessage());
			System.out.println("Commit has failed...");
			continue;
		}
		System.out.println("Commit succeeded... :-)");
		Thread.sleep(2000);
    }
  }
}