JDBC 提交和回滚示例

以下是示例，该示例使用commit和rollback在JDBC事务教程中进行了描述。

该示例代码是根据前几章中的环境和数据库设置编写的。

复制并粘贴以下示例到JDBCExample.java中，如下编译并运行：

// 步骤1.导入所需的软件包
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";
　　　// Informazioni di autenticazione del database
　　　static final String USER = "username";
　　　static final String PASS = "password";
　　　
　public static void main(String[] args) {
　　　Connection conn = null;
　　　Statement stmt = null;
　　　try{
　　　　　　// Passaggio 2: Registra il driver JDBC.
　　　　　　Class.forName("com.mysql.jdbc.Driver");
　　　　　　// Passaggio 3: Crea la connessione.
　　　　　　System.out.println("Connecting to database...");
　　　　　　conn = DriverManager.getConnection(DB_URL,USER,PASS);
　　　　　　// Passaggio 4: Imposta l'autocommit su false.
　　　　　　conn.setAutoCommit(false);
　　　　　　// Passaggio 5: Esegui la query per creare la dichiarazione.
　　　　　　// Parametri necessari per l'esempio di RS.
　　　　　　System.out.println("Creating statement...");
　　　　　　stmt = conn.createStatement(
　　　　　　　　　　　　　　　　　　　　　　　　　　　ResultSet.TYPE_SCROLL_INSENSITIVE,
　　　　　　　　　　　　　　　　　　　　　　　　　　　ResultSet.CONCUR_UPDATABLE);
　　　　　
　　　　　　// Passaggio 6: Inserisci una riga nella tabella "Employee".
　　　　　　System.out.println("Inserting one row....");
　　　　　　String SQL = "INSERT INTO Employees " +
　　　　　　　　　　　　　　　　　　　　"VALUES (106, 20, 'Rita', 'Tez')";
　　　　　　stmt.executeUpdate(SQL);　　
　　　　　　// Passaggio 7: Inserisci un'altra riga nella tabella "Employee".
　　　　　　SQL = "INSERT INTO Employees " +
　　　　　　　　　　　　　　　　　　　　"VALUES (107, 22, 'Sita', 'Singh')";
　　　　　　stmt.executeUpdate(SQL);
　　　　　　// Passaggio 8: Esegui il commit dei dati qui.
　　　　　　System.out.println("Commiting data here....");
　　　　　　conn.commit();
	　　
	　　// Passaggio 9: Ora elenca tutti i record disponibili.
　　　　　　String sql = "SELECT id, first, last, age FROM Employees";
　　　　　　ResultSet rs = stmt.executeQuery(sql);
　　　　　　System.out.println("List result set for reference....");
　　　　　　printRs(rs);
　　　　　　//Passo 10: Pulizia ambiente
　　　　　　rs.close();
　　　　　　stmt.close();
　　　　　　conn.close();
　　　}
　　　　　　//Gestisce gli errori JDBC
　　　　　　se.printStackTrace();
　　　　　　//Se ci sono errori, annulla le modifiche.
　　　　　　System.out.println("Rolling back data here....");
	　　try{
		　if(conn!=null)
　　　　　　　　　　　　conn.rollback();
　　　　　　}
　　　　　　　　　se2.printStackTrace();
　　　　　　//Fine del tentativo
　　　}
　　　　　　//Gestisce l'errore di Class.forName
　　　　　　e.printStackTrace();
　　　}
　　　　　　//Usato per chiudere risorse
　　　　　　try{
　　　　　　　　　if(stmt!=null)
　　　　　　　　　　　　stmt.close();
　　　　　　}
　　　　　　
　　　　　　}
　　　　　　try{
　　　　　　　　　if(conn!=null)
　　　　　　　　　　　　conn.close();
　　　　　　}
　　　　　　　　　se.printStackTrace();
　　　　　　}
　　　}
　　　System.out.println("Arrivederci!");
//Fine di main
　　　public static void printRs(ResultSet rs) throws SQLException{
　　　　　　//Assicurarsi di iniziare dalla prima riga
　　　　　　rs.beforeFirst();
　　　　　　while(rs.next()){
　　　　　　　　　//Ricerca per nome di colonna
　　　　　　　　　int id = rs.getInt("id");
　　　　　　　　　int age = rs.getInt("age");
　　　　　　　　　String first = rs.getString("first");
　　　　　　　　　String last = rs.getString("last");
　　　　　　　　　//Mostra valore
　　　　　　　　　System.out.print("ID: " + id);
　　　　　　　　　System.out.print(", Età: " + age);
　　　　　　　　　System.out.print(", Primo: " + first);
　　　　　　　　　System.out.println(", Ultimo: " + last);
　　　　　}
　　　　　System.out.println();
　　　//Fine di printRs()
//Fine di JDBCExample

Ora, compiliamo l'esempio sopra riportato come segue:

C:\>javac JDBCExample.java
C:\>

EsecuzioneJDBCExampleQuesto produrrà i seguenti risultati -

C:\>java JDBCExample
Connettendo al database...
Creando statement...
Inserendo una riga...
Committing dati qui...
Elenca il ResultSet per riferimento...
ID: 100, Età: 18, Primo: Zara, Cognome: Ali
ID: 101, Età: 25, Primo: Mahnaz, Cognome: Fatma
ID: 102, Età: 30, Primo: Zaid, Cognome: Khan
ID: 103, Età: 28, Primo: Sumit, Cognome: Mittal
ID: 106, Età: 20, Primo: Rita, Cognome: Tez
ID: 107, Età: 22, Primo: Sita, Cognome: Singh
Arrivederci!
C:\>