public class MariaDbJdbcTest {

	private static final String URL = "jdbc:mariadb://localhost:3306/test?useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true";

	private static final String USERNAME = "root";

	private static final String PASSWORD = "password";

	private static final String CREATE_TABLE = "CREATE table test_partitioning(created_at datetime primary key)";

	private static final String ALTER_TABLE = "ALTER table test_partitioning PARTITION BY RANGE COLUMNS( created_at ) (PARTITION test_p201605 VALUES LESS THAN ('2016-06-01'))";

	private static final String DROP_TABLE = "DROP table test_partitioning";

	@Test

	public void test() throws SQLException {

		try (Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD)) {

			executeSql(conn, CREATE_TABLE);

			executeSql(conn, ALTER_TABLE);// Success

			executeSql(conn, DROP_TABLE);

		}

	}

	@Test

	public void testPrepared() throws SQLException {

		try (Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD)) {

			executePreparedSql(conn, CREATE_TABLE);

			executePreparedSql(conn, ALTER_TABLE);// fail

			executePreparedSql(conn, DROP_TABLE);

		}

	}

	private void executePreparedSql(Connection conn, String sql) throws SQLException {

		try (PreparedStatement stmt = conn.prepareStatement(sql)) {

			stmt.execute();

			System.out.println(sql);

		}

	}

	private void executeSql(Connection conn, String sql) throws SQLException {

		try (Statement stmt = conn.createStatement();) {

			stmt.execute(sql);

			System.out.println(sql);

		}

	}

}

	public void executeQuery(boolean mustExecuteOnMaster, Results results,

			final ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters) throws SQLException {

		cmdPrologue();

		try {

			if (clientPrepareResult.getParamCount() == 0	&& !clientPrepareResult.isQueryMultiValuesRewritable()) {

				ComQuery.sendDirect(writer, clientPrepareResult.getQueryParts().get(0));

			} else {

	public void executeQuery(boolean mustExecuteOnMaster, Results results,

			final ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters) throws SQLException {

		cmdPrologue();

		try {

			if (clientPrepareResult.getParamCount() == 0 && clientPrepareResult.getQueryParts().size() == 1

					&& !clientPrepareResult.isQueryMultiValuesRewritable()) {

				ComQuery.sendDirect(writer, clientPrepareResult.getQueryParts().get(0));

			} else {