一旦你創建了Statement對象可以使用的即聲明接口的執行方法之一執行它,execute(),executeUpdate()和executeQuery()。
的execute()方法:該方法是用于執行SQL DDL語句,它返回一個布爾值,指定的天氣ResultSet對象可以被檢索。
示例import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.sql.SQLException;
import?java.sql.Statement;
public?class?Example?{
public?static?void?main(String?args[])?throws?SQLException?{
//注冊驅動程序
DriverManager.registerDriver(new?com.mysql.jdbc.Driver());
//獲得連接
String?mysqlUrl?=?"jdbc:mysql://localhost/sampleDB";
Connection?con?=?DriverManager.getConnection(mysqlUrl,?"root",?"password");
System.out.println("Connection?established......");
//創建語句
Statement?stmt?=?con.createStatement();
//執行語句
String?createTable?=?"CREATE?TABLE?Employee(?"
+?"Name?VARCHAR(255),?"
+?"Salary?INT?NOT?NULL,?"
+?"Location?VARCHAR(255))";
boolean?bool?=?stmt.execute(createTable);
System.out.println(bool);
}
}
輸出結果Connection?established......
false
executeUpdate():此方法用于執行諸如插入,更新,刪除之類的語句。它返回一個整數值,表示受影響的行數。
示例import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.sql.SQLException;
import?java.sql.Statement;
public?class?ExecuteUpdateExample?{
public?static?void?main(String?args[])?throws?SQLException?{
//注冊驅動程序
DriverManager.registerDriver(new?com.mysql.jdbc.Driver());
//獲得連接
String?mysqlUrl?=?"jdbc:mysql://localhost/sampleDB";
Connection?con?=?DriverManager.getConnection(mysqlUrl,?"root",?"password");
System.out.println("Connection?established......");
//創建語句
Statement?stmt?=?con.createStatement();
String?insertData?=?"INSERT?INTO?Employee("
+?"Name,?Salary,?Location)?VALUES?"
+?"('Amit',?30000,?'Hyderabad'),?"
+?"('Kalyan',?40000,?'Vishakhapatnam'),?"
+?"('Renuka',?50000,?'Delhi'),?"
+?"('Archana',?15000,?'Mumbai')";
int?i?=?stmt.executeUpdate(insertData);
System.out.println("Rows?inserted:?"+i);
}
}
輸出結果Connection?established......
Rows?inserted:?4
executeQuery():此方法用于執行返回表格數據的語句(示例select)。它返回ResultSet類的對象。
示例import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.sql.ResultSet;
import?java.sql.SQLException;
import?java.sql.Statement;
public?class?ExecuteQueryExample?{
public?static?void?main(String?args[])?throws?SQLException?{
//注冊驅動程序
DriverManager.registerDriver(new?com.mysql.jdbc.Driver());
//獲得連接
String?mysqlUrl?=?"jdbc:mysql://localhost/sampleDB";
Connection?con?=?DriverManager.getConnection(mysqlUrl,?"root",?"password");
System.out.println("Connection?established......");
//創建語句
Statement?stmt?=?con.createStatement();
//檢索數據
ResultSet?rs?=?stmt.executeQuery("Select?*from?Employee");
while(rs.next())?{
System.out.print("Name:?"+rs.getString("Name")+",?");
System.out.print("Salary:?"+rs.getInt("Salary")+",?");
System.out.print("City:?"+rs.getString("Location"));
System.out.println();
}
}
}
輸出結果Connection?established......
Name:?Amit,?Salary:?30000,?City:?Hyderabad
Name:?Kalyan,?Salary:?40000,?City:?Vishakhapatnam
Name:?Renuka,?Salary:?50000,?City:?Delhi
Name:?Archana,?Salary:?15000,?City:?Mumbai