加載JDBC驅(qū)動(dòng)
只需要在第一次連接數(shù)據(jù)庫(kù)時(shí)加載,java6以后我們可以直接這樣加載:
*我在本系列教程中用mysql示例。
- 需要導(dǎo)入jar包:mysql-connector-java-5.0.8-bin.jar(版本和下載網(wǎng)站自己挑)
- 如果是web程序,把jar包放到WebRoot/WEB-INF/lib/下
- 如果是普通java項(xiàng)目,將jar包導(dǎo)入到自己項(xiàng)目的lib庫(kù)中。
- 然后加載驅(qū)動(dòng)如下
Class.forName("com.mysql.jdbc.Driver");
打開連接
打開連接的話需要調(diào)用DriverManager類中的getConnection()方法,該方法有三個(gè)重載方法。如下所示
public static Connection getConnection(String url,
java.util.Properties info) throws SQLException {
return (getConnection(url, info, Reflection.getCallerClass()));
}
public static Connection getConnection(String url,
String user, String password) throws SQLException {
java.util.Properties info = new java.util.Properties();
if (user != null) {
info.put("user", user);
}
if (password != null) {
info.put("password", password);
}
return (getConnection(url, info, Reflection.getCallerClass()));
}
public static Connection getConnection(String url)
throws SQLException {
java.util.Properties info = new java.util.Properties();
return (getConnection(url, info, Reflection.getCallerClass()));
}
大概看下它的參數(shù)名字應(yīng)該知道它需要什么吧。在這里我只解釋第一個(gè)方法。Properties info 這個(gè)參數(shù)其實(shí)也是user和password的打包。其實(shí)和方法二一樣。
實(shí)例:
public class Main {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/user";
String user = "root";
String password = "root";
Connection connection = null;
Statement statement = null;
ResultSet resultSet = null;
try {
// 1.加載驅(qū)動(dòng)//com.mysql.jdbc.Driver
Class.forName("com.mysql.jdbc.Driver");
// 2.獲取連接
connection = DriverManager.getConnection(url, user, password);
// 3.獲取用于向數(shù)據(jù)庫(kù)發(fā)送SQL的Statement對(duì)象
statement = connection.createStatement();
// 4.執(zhí)行sql,獲取數(shù)據(jù)
resultSet = statement.executeQuery("SELECT * FROM user;");
// 解析數(shù)據(jù)
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("username");
String psd = resultSet.getString("birthday");
String email = resultSet.getString("sex");
String birthday = resultSet.getString("address");
System.out.println(" " + name + " " + psd + " " + email
+ " " + birthday);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
//5.關(guān)閉連接,釋放資源
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
resultSet = null;
}
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
statement = null;
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
connection = null;
}
}
}
}
數(shù)據(jù)查詢
數(shù)據(jù)查詢需要我們將sql發(fā)送給數(shù)據(jù)庫(kù),我們需要?jiǎng)?chuàng)建一個(gè)Statement對(duì)象。
Statement statement = connection.createStatement();
因?yàn)镾tatement對(duì)象可以執(zhí)行sql
String sql = "select * from user";
ResultSet resultSet = statement.executeQuery(sql);
當(dāng)執(zhí)行一個(gè)sql查詢的時(shí)候,會(huì)得道一個(gè)ResultSet對(duì)象,它里面放著查詢的結(jié)果。
ResultSet resultSet = statement.executeQuery("SELECT * FROM user;");
那怎樣獲取user表中對(duì)應(yīng)列的數(shù)據(jù)呢?
resultSet .getString ("columnName");
resultSet .getLong ("columnName");
resultSet .getInt ("columnName");
resultSet .getDouble ("columnName");
resultSet .getBigDecimal("columnName");
或者通過(guò)第幾列進(jìn)行查詢。
resultSet .getString (1);
resultSet .getLong (2);
resultSet .getInt (3);
resultSet .getDouble (4);
resultSet .getBigDecimal(5);
如果你想知道對(duì)應(yīng)列名的index值(位于第幾列),可以這樣
int columnIndex = resultSet .findColumn("columnName");
數(shù)據(jù)修改/刪除
為什么要把修改和刪除放一塊說(shuō)呢,因?yàn)樗麄兒筒樵冋{(diào)用不一樣的方法。
查詢我們調(diào)用executeQuery()方法,修改和刪除我們需要用executeUpdate()方法。
舉個(gè)簡(jiǎn)單的例子:
//更新數(shù)據(jù)(也叫修改數(shù)據(jù))
String sql = "update user set name='fantj' where id=1";
int rowsAffected = statement.executeUpdate(sql); //rowsAffected是影響行數(shù)的意思
//刪除數(shù)據(jù)
String sql = "delete from user where id=123";
int rowsAffected = statement.executeUpdate(sql);
關(guān)閉連接
為了安全性和項(xiàng)目性能,我們盡量在執(zhí)行完操作之后關(guān)閉連接(雖然高版本jvm會(huì)自動(dòng)關(guān)閉它,但是這也需要檢測(cè)浪費(fèi)cpu資源)。
關(guān)閉連接分為三個(gè)部分。
- resultSet.close();
- statement.close();
- connection.close();
注意先后問(wèn)題。