public static void main()

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