MariaDB [(none)]> GRANT REPLICATION SLAVE ON *.* TO 'repadmin'@'%' IDENTIFIED BY 'secure_password';
Query OK, 0 rows affected (0.00 sec)
 
MariaDB [(none)]> CREATE DATABASE replicationdb CHARACTER SET utf32 COLLATE utf32_general_ci;
Query OK, 1 row affected (0.00 sec)
 
MariaDB [(none)]> use replicationdb
Database changed
 
MariaDB [replicationdb]> CREATE TABLE test1(val int, descr varchar(50));
Query OK, 0 rows affected (0.01 sec)
 
MariaDB [replicationdb]> insert into test1 values(1,'One');
Query OK, 1 row affected (0.00 sec)

MariaDB [replicationdb]> SHOW MASTER STATUS;
+------------------+----------+--------------+------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+------------------+----------+--------------+------------------+
| mysql-bin.000001 |     2631 |              |                  |
+------------------+----------+--------------+------------------+
1 row in set (0.00 sec)
 
MariaDB [replicationdb]> SELECT BINLOG_GTID_POS("mysql-bin.000001",2631);
+------------------------------------------+
| BINLOG_GTID_POS("mysql-bin.000001",2631) |
+------------------------------------------+
| 0-1-8                                    |
+------------------------------------------+

MariaDB [(none)]> SET GLOBAL gtid_slave_pos = "0-1-8";
Query OK, 0 rows affected (0.00 sec)
 
MariaDB [(none)]> change master to master_host='server3.domain.com', master_port=3316,master_user='repadmin', 
               -> master_password='secure_password', master_use_gtid=slave_pos;
Query OK, 0 rows affected (0.00 sec)
 
MariaDB [(none)]> start slave;
Query OK, 0 rows affected (0.00 sec)
 
MariaDB [(none)]> SHOW SLAVE STATUS\G
*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: server3.domain.com
                  Master_User: repadmin
                  Master_Port: 3316
                Connect_Retry: 60
              Master_Log_File: mysql-bin.000001
          Read_Master_Log_Pos: 2631
               Relay_Log_File: mysql01-relay-bin.000002
                Relay_Log_Pos: 640
        Relay_Master_Log_File: mysql-bin.000001
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes
              Replicate_Do_DB:
          Replicate_Ignore_DB:
           Replicate_Do_Table:
       Replicate_Ignore_Table:
      Replicate_Wild_Do_Table:
  Replicate_Wild_Ignore_Table:
                   Last_Errno: 0
                   Last_Error:
                 Skip_Counter: 0
          Exec_Master_Log_Pos: 2631
              Relay_Log_Space: 940
              Until_Condition: None
               Until_Log_File:
                Until_Log_Pos: 0
           Master_SSL_Allowed: No
           Master_SSL_CA_File:
           Master_SSL_CA_Path:
              Master_SSL_Cert:
            Master_SSL_Cipher:
               Master_SSL_Key:
        Seconds_Behind_Master: 0
Master_SSL_Verify_Server_Cert: No
                Last_IO_Errno: 0
                Last_IO_Error:
               Last_SQL_Errno: 0
               Last_SQL_Error:
  Replicate_Ignore_Server_Ids:
             Master_Server_Id: 1
               Master_SSL_Crl:
           Master_SSL_Crlpath:
                   Using_Gtid: Slave_Pos
                  Gtid_IO_Pos: 0-1-8
      Replicate_Do_Domain_Ids:
  Replicate_Ignore_Domain_Ids:
                Parallel_Mode: conservative
1 row in set (0.00 sec)

MariaDB [replicationdb]> insert into replicationdb.test1 values(2,'Two');
Query OK, 1 row affected (0.00 sec)
 
MariaDB [replicationdb]> select * from replicationdb.test1;
+------+-------+
| val  | descr |
+------+-------+
|    1 | One   |
|    2 | Two   |
+------+-------+
2 rows in set (0.00 sec)

MariaDB [(none)]>  select * from replicationdb.test1;
+------+-------+
| val  | descr |
+------+-------+
|    1 | One   |
|    2 | Two   |
+------+-------+
2 rows in set (0.00 sec)

package jdbcdemo1;
 
import org.mariadb.jdbc.Driver;
 
import java.sql.ResultSet;
import java.util.Properties;
import java.sql.Connection;
import java.sql.SQLException;
 
public class jdbcdemo1 {
  public static void main(String[] args) throws Exception {
    Driver driver = new Driver();
    Properties props = new Properties();
    ResultSet rs;
    String variable_value;
    Connection conn = null;
    String JDBC_URL = "jdbc:mysql:replication://address=(host=192.168.56.103)(port=3316)(type=master),"
    				+ "address=(host=192.168.56.104)(port=3316)(type=slave)";
 
    props.put("retriesAllDown","5");
    props.put("user", "yjaquier");
    props.put("password", "secure_password");
 
    System.out.println("\n------------ MariaDB Connector/J and MariaDB Replication Testing ------------\n");
 
    System.out.println("Trying connection...");
    try {
    	conn = driver.connect(JDBC_URL, props);
    	}
    catch (SQLException e) {
    	System.out.println("Connection Failed!");
    	System.out.println("Error cause: "+e.getCause());
    	System.out.println("Error message: "+e.getMessage());
    	return;
    }
 
    System.out.println("Connection established...");
 
    for(int i=1; i <= 1000; i++) {
 
// Read write query that can be performed ONLY on master server
 
        System.out.println("\nQuery "+i+": ");
    	// Fake Read Write SQL statement (just to see where it goes)
    	System.out.println("Read Write query...");
    	try {
    		conn.setReadOnly(false);
    	}
    	catch (SQLException e) {
    		System.out.println("Connection read write property set has failed...");
    	}
 
    	if (conn.isReadOnly() == false) {
    		try {
    			rs = conn.createStatement().executeQuery("SELECT variable_value FROM information_schema.global_variables " +
                                                                 "WHERE variable_name='hostname'");
    			while (rs.next()) {
    				variable_value = rs.getString("variable_value");
    				System.out.println("variable_value : " + variable_value);
    			}
    		}
    		catch (SQLException e) {
    			System.out.println("Read/write query has failed...");
    		}
    	}
 
// Read Only statement (that can also be done on master server if all slaves are down)
    	System.out.println("Read Only query...");
    	try {
    		conn.setReadOnly(true);	
    	}
    	catch (SQLException e) {
    		System.out.println("Connection read only property set has failed...");
    	}
   		try {
   			rs = conn.createStatement().executeQuery("SELECT variable_value FROM information_schema.global_variables " +
                                                                 "WHERE variable_name='hostname'");
   			while (rs.next()) {
   				variable_value = rs.getString("variable_value");
   				System.out.println("variable_value : " + variable_value);
   				}
   			}
   		catch (SQLException e) {
   			System.out.println("Read only query has failed...");
   			}
 
    	Thread.sleep(2000);
    }
    conn.close();
  }
}