JDBC FAQ для начинающих

package faq.jdbc;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Arrays;
import java.util.Properties;
 
/** @author mutagen */
public class JDBCExamples {
 
    public static void main(String[] args) throws Exception {
        /**
         * Код для использования требует наличия в CLASS_PATH библиотек: MYSQL, Oracle, H2, etc... позаботьтесь об этом,
         * также позаботьтесь о работоспособности выбранной вами БД перед тем как соединяться с ней. Всё демо будет
         * происходить на H2, но код для инициализации других БД тоже присутствует
         */
        //Если вы пользуетесь Java 6+ то вызывать loadDriver - не обязательно
        loadDriver("org.h2.Driver");
//        loadDriver("org.hsqldb.jdbcDriver");
//        loadDriver("com.mysql.jdbc.Driver");
//        loadDriver("org.postgresql.Driver");
//        loadDriver("oracle.jdbc.OracleDriver");
 
 
        Connection connH2 = getConnection("jdbc:h2:mem:", createPropsShort("~tst", "luser", "pass"));
//        Connection connHSQL = getConnection("jdbc:hsqldb:", createPropsShort("db_name", "luser", "pass"));
//        Connection connPostgre = getConnection("jdbc:postgresql:", createPropsGeneral("localhost", "5432", "db_name", "luser", "pass"));
//        Connection connMysql = getConnection("jdbc:mysql:", createPropsGeneral("localhost", "3306", "db_name", "luser", "pass"));
//        Connection connOracle = getConnection("jdbc:oracle:thin:", createPropsOracle("localhost", "1521", "XE", "oracle", "oracle"));
 
 
//        создадим таблицу
        String createTable = "create table IF NOT EXISTS TST_TAB (ID INT, NAME VARCHAR(50));";
        Statement stH2 = connH2.createStatement();
        stH2.execute(createTable);
 
 
//        наполним данными
        String[] insert = {"insert into TST_TAB (id, name) values (1, 'abc');",
            "insert into TST_TAB (id, name) values (2, 'abcabc');",
            "insert into TST_TAB (id, name) values (3, 'abcabcabc');"};
        for (String sql : insert) {
            stH2.execute(sql);
        }
        System.out.println();
 
//       выполним простую выборку
        String select = "select * from TST_TAB;";
        ResultSet rs = stH2.executeQuery(select);
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " " + rs.getString(2));
        }
        System.out.println();
 
//        выполним подготовленный SQL стейтмент
        String sqlPrepared = "select * from TST_TAB where id=?";
        PreparedStatement ps = connH2.prepareStatement(sqlPrepared);
 
        ps.setInt(1, 2);
        rs = ps.executeQuery();
 
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " " + rs.getString(2));
        }
        System.out.println();
 
//        выполним простое удаление через стейтмент
        String delete = "DELETE FROM TST_TAB WHERE id=1;";
        int deletedRows = stH2.executeUpdate(delete);
        System.out.println("Удалено " + deletedRows + " рядов");
//        посмотрим что там осталось
        select = "select * from TST_TAB;";
        rs = stH2.executeQuery(select);
        System.out.println("осталось:");
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " " + rs.getString(2));
        }
        System.out.println();
 
//        выполним удаление чере препейред стейтмент
        sqlPrepared = "DELETE FROM TST_TAB WHERE id=?";
        ps = connH2.prepareStatement(sqlPrepared);
 
        ps.setInt(1, 2);
        deletedRows = ps.executeUpdate();
 
        System.out.println("Удалено " + deletedRows + " рядов");
//        посмотрим что там осталось
        select = "select * from TST_TAB;";
        rs = stH2.executeQuery(select);
        System.out.println("осталось:");
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " " + rs.getString(2));
        }
 
//        а теперь добавим через препаред батч
        sqlPrepared = "insert into TST_TAB (id, name) values (?, ?)";
        ps = connH2.prepareStatement(sqlPrepared);
        for (int i = 0; i < 10; i++) {
            ps.setInt(1, i);
            ps.setString(2, "abc" + i);
            ps.addBatch();
        }
        int [] insertedRows = ps.executeBatch();
 
        System.out.println("Вставлено " + insertedRows.length + " рядов");
//        посмотрим что там осталось
        select = "select * from TST_TAB;";
        rs = stH2.executeQuery(select);
        System.out.println("теперь стало:");
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " " + rs.getString(2));
        }
 
 
    }
 
    /**
     * @param db строка для соединения с базой в формате JDBC
     * @param props параметры для драйвера, такие как пользователь, пароль, порт и тд
     * @return соединение с БД
     * @throws SQLException
     */
    public static Connection getConnection(String db, Properties props) throws SQLException {
        Connection conn = DriverManager.getConnection(db, props);
        System.out.println(conn);
        return conn;
    }
 
//    для разных баз требуются различные параметры
    /**
     * @param host адрес хоста с БД
     * @param port поорт на котором БД прослушивает соединения
     * @param database имя базы
     * @param user пользователь
     * @param password и его пароль
     * @return параметры для соединения с MySQL
     */
    public static Properties createPropsGeneral(String host, String port, String database, String user, String password) {
        Properties props = new Properties();
        props.put("host", host);
        props.put("port", port);
        props.put("database", database);
        props.put("user", user);
        props.put("password", password);
        return props;
    }
 
    /**
     * @param host адрес хоста с БД
     * @param port поорт на котором листенер прослушивает соединение для указанного SID
     * @param sid идентификатор схемы БД
     * @param user пользоватьель
     * @param password и его пароль
     * @return параметры для соединения с Oracle DB
     */
    public static Properties createPropsOracle(String host, String port, String sid, String user, String password) {
        Properties props = new Properties();
        props.put("host", host);
        props.put("port", port);
        props.put("sid", sid);
        props.put("user", user);
        props.put("password", password);
        return props;
    }
 
    /**
     * @param database имя базы
     * @param user пользоватьель
     * @param password и его пароль
     * @return параметры для соединения с PostgreSQL
     */
    public static Properties createPropsShort(String database, String user, String password) {
        Properties props = new Properties();
        props.put("database", database);
        props.put("user", user);
        props.put("password", password);
        return props;
    }
 
    /**
     * Загружает JDBC драйвер по имени. 
     * На самом деле это лишнее для всех современных БД. Вызывать loadDriver - НЕ обязательно
     * @param driverFullName полное имя класса в котором реализован интерфейс вызова Driver для JDBC
     * @return загруженный класс
     * @throws ClassNotFoundException
     */
    public static Class loadDriver(String driverFullName) throws ClassNotFoundException {
        Class c = Class.forName(driverFullName);
        System.out.println(c);
        return c;
    }
}

package faq.jdbc;
 
import static faq.jdbc.JDBCExamples.createPropsShort;
import static faq.jdbc.JDBCExamples.getConnection;
import static faq.jdbc.JDBCExamples.loadDriver;
import java.awt.BorderLayout;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Vector;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTable;
 
/** @author mutagen */
public class JDBCTableExample extends JFrame {
 
    static class TableFromDatabase extends JFrame {
 
        public TableFromDatabase(Connection connection) {
 
            Vector columnNames = new Vector();
            Vector data = new Vector();
 
            try {
                //  прочитаем всё из таблицы
                String sql = "Select * from TST_TAB";
                Statement stmt = connection.createStatement();
                ResultSet rs = stmt.executeQuery(sql);
                ResultSetMetaData md = rs.getMetaData();
                int columns = md.getColumnCount();
 
                //  получим имена колонок
                for (int i = 1; i <= columns; i++) {
                    columnNames.addElement(md.getColumnName(i));
                }
 
                //  считаем ряды
                while (rs.next()) {
                    Vector row = new Vector(columns);
                    for (int i = 1; i <= columns; i++) {
                        row.addElement(rs.getObject(i));
                    }
                    data.addElement(row);
                }
                rs.close();
                stmt.close();
                connection.close();
            } catch (Exception e) {
                System.out.println(e);
            }
 
            //  создадим таблицу с данными из БД
            JTable table = new JTable(data, columnNames) {
                public Class getColumnClass(int column) {
                    for (int row = 0; row < getRowCount(); row++) {
                        Object o = getValueAt(row, column);
                        if (o != null) {
                            return o.getClass();
                        }
                    }
                    return Object.class;
                }
            };
 
            JScrollPane scrollPane = new JScrollPane(table);
            getContentPane().add(scrollPane);
            JPanel buttonPanel = new JPanel();
            getContentPane().add(buttonPanel, BorderLayout.SOUTH);
        }
 
    }
 
    public static void main(String[] args) throws Exception {
        Connection con = prepareData();
        TableFromDatabase frame = new TableFromDatabase(con);
        frame.setDefaultCloseOperation(EXIT_ON_CLOSE);
        frame.pack();
        frame.setVisible(true);
    }
 
//    подготовим таблицу и данные для отображения и вернём соединение с базой
    static Connection prepareData() throws Exception {
        JDBCExamples jDBCExamples = new JDBCExamples();
        Class h2Class = loadDriver("org.h2.Driver");
        Connection connH2 = getConnection("jdbc:h2:mem:", createPropsShort("~tst", "luser", "pass"));
        String createTable = "create table IF NOT EXISTS TST_TAB (ID INT, NAME VARCHAR(50), ADDRESS VARCHAR(100));";
        Statement stH2 = connH2.createStatement();
        stH2.execute(createTable);
        List<String> insert = new ArrayList<String>() {
            {
                for (int i = 0; i <= 30; i++) {
                    add("insert into TST_TAB (id, name, address) values (" + i + ", 'name" + i + "', 'street" + i + "');");
                }
            }
        };
        for (String sql : insert) {
            stH2.execute(sql);
        }
        return connH2;
    }
}

package faq.jdbc;
 
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
 
/** @author mutagen */
public class JDBCCallDBProcedureExample {
 
    public static void main(String[] args) throws Exception {
        Connection conn = createDB();
        createTable(conn);
        fillDB(conn);
        showTableContent(conn);
        createProcedure(conn);
        User u = new User(100, "user_100", "addr_100");
        callProcedure(conn, u);
        showTableContent(conn);
    }
 
//    создадим вызываемую процедуру в БД
    static void createProcedure(Connection conn) throws Exception {
        String sql = "CREATE PROCEDURE new_user(user_id INT, name VARCHAR(50), address VARCHAR(100)) MODIFIES SQL DATA "
                + " INSERT INTO TST_TAB VALUES (user_id, name, address)";
        Statement st = conn.createStatement();
        st.execute(sql);
    }
 
//    вызовем процедуру из БД
    static void callProcedure(Connection conn, User user) throws Exception {
        String sql = "{call new_user(?,?,?)}";
        CallableStatement cst = conn.prepareCall(sql);
        cst.setInt(1, user.getId());
        cst.setString(2, user.getName());
        cst.setString(3, user.getAddress());
        cst.execute();
    }
 
//    создадим тестовую БД в памяти
    static Connection createDB() throws Exception {
        Class.forName("org.hsqldb.jdbcDriver");
        Connection conn = DriverManager.getConnection("jdbc:hsqldb:mem:tstDB", "user", "pass");
        return conn;
    }
 
//    создадим тестовую таблицу
    static void createTable(Connection conn) throws Exception {
        String createTable = "create table IF NOT EXISTS TST_TAB (ID INT, NAME VARCHAR(50), ADDRESS VARCHAR(100));";
        Statement st = conn.createStatement();
        st.execute(createTable);
    }
 
//  наполним БД чем нибудь )
    static void fillDB(Connection conn) throws Exception {
        PreparedStatement pst = conn.prepareStatement("insert into TST_TAB values (?, ?, ?)");
        for (int i = 0; i < 3; i++) {
            pst.setInt(1, i);
            pst.setString(2, "name-" + i);
            pst.setString(3, "address-" + i);
            pst.addBatch();
        }
        pst.executeBatch();
    }
 
//  посмотрим что в таблице
    static void showTableContent(Connection conn) throws Exception {
        String sql = "Select * from TST_TAB";
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        while (rs.next()) {
            System.out.println(rs.getInt(1) + " | " + rs.getString(2) + " | " + rs.getString(3));
        }
        System.out.println("");
    }
 
// простенький класс
    static class User {
 
        int id;
        String name;
        String address;
 
        public User(int id, String name, String address) {
            this.id = id;
            this.name = name;
            this.address = address;
        }
 
        public int getId() {
            return id;
        }
 
        public String getName() {
            return name;
        }
 
        public String getAddress() {
            return address;
        }
    }
}

connH2

Connection connH2 = getConnection("jdbc:h2:mem:", createPropsShort("~tst", "luser", "pass"));