English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
这是将批处理与Statement对象一起使用的典型步骤序列-
使用这两种createStatement()方法创建一个Statement对象。
使用将自动提交设置为false setAutoCommit()。
使用addBatch()创建的语句对象上的方法将任意多的SQL语句添加到批处理中。
使用executeBatch()创建的语句对象上的方法执行所有SQL语句。
最后,使用commit()方法提交所有更改。
该示例代码是根据前几章中的环境和数据库设置编写的。
复制并粘贴以下示例到JDBCExample.java中,如下编译并运行:
// 导入所需的软件包 import java.sql.*; public class JDBCExample { // JDBC驱动程序名称和数据库URL static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB_URL = "jdbc:mysql://localhost/EMP"; // Данные для доступа к базе данных static final String USER = "username"; static final String PASS = "password"; public static void main(String[] args) { Connection conn = null; Statement stmt = null; try{ // Регистрация JDBC-драйвера Class.forName("com.mysql.jdbc.Driver"); // Открываем соединение System.out.println("Connecting to database..."); conn = DriverManager.getConnection(DB_URL,USER,PASS); // Создание statements System.out.println("Creating statement..."); stmt = conn.createStatement(); // Установим автоматическую передачу в false conn.setAutoCommit(false); // Давайте сначала выберем все записи и покажем их //Обработка JDBC ошибок // Создание SQL-запроса String SQL = "INSERT INTO Employees (id, first, last, age) " + "VALUES(200,'Zia', 'Ali', 30)"; // Добавление上面的 SQL-запроса в пакет stmt.addBatch(SQL); // Создание еще одного SQL-запроса SQL = "INSERT INTO Employees (id, first, last, age) " + "VALUES(201,'Raj', 'Kumar', 35)"; // Добавление上面的 SQL-запроса в пакет stmt.addBatch(SQL); // Создание еще одного SQL-запроса SQL = "UPDATE Employees SET age = 35 " + "WHERE id = 100"; // Добавление上面的 SQL-запроса в пакет stmt.addBatch(SQL); // Создание массива int для сохранения возвращаемых значений int[] count = stmt.executeBatch(); // Выберем все записи и покажем их. printRows( stmt ); // Очистка окружающей среды //Обработка JDBC ошибок } catch(SQLException se2){ catch(SQLException se){ } //Обработка ошибки Class.forName se.printStackTrace(); e.printStackTrace(); finally{ } //Для закрытия ресурсов if(stmt!=null) try{ stmt.close(); catch(SQLException se2){ } } try{ if(conn!=null) catch(SQLException se){ } se.printStackTrace(); } } System.out.println("Прощай!"); //Закончить main public static void printRows(Statement stmt) throws SQLException{ System.out.println("Отображение доступных строк..."); //Выберем все записи и покажем их. String sql = "SELECT id, first, last, age FROM Employees"; ResultSet rs = stmt.executeQuery(sql); while(rs.next()){ //Искать по имени столбца int id = rs.getInt("id"); int age = rs.getInt("age"); String first = rs.getString("first"); String last = rs.getString("last"); //Отображение значений System.out.print("ID: " + id); System.out.print(", Возраст: " + age); System.out.print(", Имя: " + first); System.out.println(", Последний: " + last); } System.out.println(); rs.close(); //Закончить printRows() //Закончить JDBCExample
Теперь давайте скомпилируем приведенный выше пример, как показано ниже:
C:\>javac JDBCExample.java C:\>
Во время выполненияJDBCExampleОно произведет следующие результаты-
C:\>java JDBCExample Подключение к базе данных... Создание указания... Отображение доступных строк... ID: 95, Возраст: 20, Имя: Sima, Фамилия: Chug ID: 100, Возраст: 18, Имя: Zara, Фамилия: Ali ID: 101, Возраст: 25, Имя: Mahnaz, Фамилия: Fatma ID: 102, Возраст: 30, Имя: Zaid, Фамилия: Khan ID: 103, Возраст: 30, Имя: Sumit, Фамилия: Mittal ID: 110, Возраст: 20, Имя: Sima, Фамилия: Chug Отображение доступных строк... ID: 95, Возраст: 20, Имя: Sima, Фамилия: Chug ID: 100, Возраст: 35, Имя: Zara, Фамилия: Ali ID: 101, Возраст: 25, Имя: Mahnaz, Фамилия: Fatma ID: 102, Возраст: 30, Имя: Zaid, Фамилия: Khan ID: 103, Возраст: 30, Имя: Sumit, Фамилия: Mittal ID: 110, Возраст: 20, Имя: Sima, Фамилия: Chug ID: 200, Возраст: 30, Имя: Zia, Фамилия: Ali ID: 201, Возраст: 35, Имя: Raj, Фамилия: Kumar До свидания! C:\>