JDBC Setup
import java.sql.Connection; import java.sql.DriverManager; // Define the connection URL String url = "jdbc:mysql://localhost:3306/mydatabase"; // Define database credentials String username = "username"; String password = "password"; // Establish the connection Connection connection = DriverManager.getConnection(url, username, password);import java.sql.Statement; Statement statement = connection.createStatement(); String sql = "SELECT * FROM mytable"; statement.executeQuery(sql);import java.sql.PreparedStatement; String sql = "INSERT INTO mytable (column1, column2) VALUES (?, ?)"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setString(1, "value1"); preparedStatement.setInt(2, 42); preparedStatement.executeUpdate();import java.sql.CallableStatement; String sql = "{call my_stored_procedure(?, ?)}"; CallableStatement callableStatement = connection.prepareCall(sql); callableStatement.setString(1, "param1"); callableStatement.setInt(2, 123); callableStatement.execute();import java.sql.ResultSet; ResultSet resultSet = statement.executeQuery("SELECT * FROM mytable"); while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("name"); // Process data }Statement statement = connection.createStatement(); statement.addBatch("INSERT INTO mytable (name) VALUES ('John')"); statement.addBatch("INSERT INTO mytable (name) VALUES ('Jane')"); int[] result = statement.executeBatch();try { // JDBC code } catch (SQLException e) { e.printStackTrace(); } finally { // Close resources if (connection != null) { connection.close(); } }
Last updated