package dev.regatta.jdbc1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class DatabaseExample {
public static void main(String[] args) {
// Connection details
String url = "jdbc:regatta:aaa.bbb.ccc.ddd:ppp";
String user = "MyUserName";
String password = "SomeSophisticatedPassword";
try {
try (Connection conn = DriverManager.getConnection(url, user, password)) {
try (Statement stmt = conn.createStatement()) {
String createTableSQL =
"CREATE TABLE employees (" +
"employee_key INT PRIMARY KEY INDEX, " +
"employee_name VARCHAR(40) NOT NULL, " +
"employee_salary INT, " +
"employee_department VARCHAR(50) NOT NULL" +
")";
stmt.executeUpdate(createTableSQL);
String insertValuesSQL =
"INSERT INTO employees " +
"(employee_key, employee_name, employee_salary, employee_department) " +
"VALUES " +
"(1, 'John Doe', 10932, 'DevOps'), " +
"(2, 'Richard Roe', 18324, 'Legal'), " +
"(3, 'Jane Roe', 20411, 'SoftwareDev'), " +
"(4, 'Rachel Roe', 19555, 'Support')";
stmt.executeUpdate(insertValuesSQL);
ResultSet rs = stmt.executeQuery("SELECT * FROM employees");
while (rs.next()) {
System.out.println("Employee Key: " + rs.getInt("employee_key"));
System.out.println("Employee Name: " + rs.getString("employee_name"));
System.out.println("Employee Salary: " + rs.getInt("employee_salary"));
System.out.println("Employee Department: " + rs.getString("employee_department"));
System.out.println();
}
stmt.executeUpdate("DROP TABLE employees");
}
}
} catch (SQLException e) {
System.out.println("Database access error.");
e.printStackTrace();
}
}
}