in code/src/main/java/com/amazonaws/mariadbblog/DbClient.java [97:153]
public static void main(String[] args) {
String primaryNode = "";
String secondaryNode = "";
try {
// STEP 2: Register JDBC driver
Class.forName(JDBC_DRIVER);
// STEP 3: Open a connection
populateSecret();
System.out.println("Connecting to database...");
try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS)) {
System.out.println("Connected successfully to database...");
// STEP 4: Execute a query
//System.out.println("Querying table from the connected database...");
try (Statement stmt = conn.createStatement()) {
//String sql = "SELECT SERVER_ID, SESSION_ID FROM INFORMATION_SCHEMA.REPLICA_HOST_STATUS";
// String sql = "USE auroradbtest;" + "INSERT INTO VENDORS (id, name, CEO, VAT_Number) VALUES (3, 'Microsoft', 'Satya Nadella', 33333)";
//System.out.println("Printing primary and replica nodes of the db cluster...");
/*
ResultSet rs = stmt.executeQuery("SELECT SERVER_ID, SESSION_ID FROM INFORMATION_SCHEMA.REPLICA_HOST_STATUS");
while (rs.next()) {
if (rs.getString(2).equals("MASTER_SESSION_ID"))
primaryNode = rs.getString(1); // the node that is the primary currently has a session named MASTER_SESSION_ID
//System.out.println(rs);
else
secondaryNode += (("".equals(secondaryNode)) ? "" : ",") + rs.getString(1); // other nodes ares replicas
//Printing out endpoint with their session_Id indicating which is primary or replica
System.out.println(rs.getString(1)+ " "+rs.getString(2));
}
*/
System.out.println("Creating table from the connected database...");
String sql = "USE auroradbtest;" + "CREATE TABLE VENDORS" + "(id INTEGER not NULL, " + " name VARCHAR(255), "
+ " CEO VARCHAR(255), " + " VAT_Number INTEGER, " + " PRIMARY KEY ( id ))";
stmt.executeUpdate(sql);
System.out.println("Table created successfully...");
// stmt.executeUpdate(sql);
// System.out.println("Deleted table in a given database...");
} catch (SQLException e) {
// Handle errors for JDBC
e.printStackTrace();
}
} catch (SQLException e) {
// Handle errors for JDBC
e.printStackTrace();
}
} catch (Exception e) {
// Handle errors for Class.forName
e.printStackTrace();
}
System.out.println("Goodbye!");
}// end main