Java遇上MySQL
來源：程序員人生 發布時間：2015-03-02 08:13:11 閱讀次數：3047次
1、簡單Java Bean==>可以被序列化。需要準備的材料為：
①定義n個私有成員變量，在連接數據庫中，則需要定義與我們所建的表對應的n個字段。
②實現全部成員變量的set和get方法。
③實現無參數和帶全參數的構造方法。
④重寫toString方法。
⑤實現接口Serializable。
2、在SQL中，1條記錄像當于1個對象，所以需要new1個對象保存它。
3、在Java中連接數據庫所需的步奏<由于MySQL不是系統自帶的庫，所以需要我們手動導包>
①導數據庫包===>建文件夾===>粘貼MySQL數據庫的jar包到文件夾===>右鍵Build Path===>configure Build Path===>Libraries===>AddJARs。
②建class文件。
③前期準備做足以后，就是我們期待已久的通過Java連接數據庫了！
A：加載驅動
eg：Class.forName("org.gjt.mm.mysql.Driver"); // org.gjt.mm===>MySQL的特有寫法； mysql===>剛剛我們建的文件夾的名字； Driver===>類名
B：連接數據庫
eg：Connection con = null;
String url = "jdbc:mysql://localhost:3306/Lee_My"; // jdbc:mysql===>甚么類型的數據庫； localhost===>所連接的數據的IP； 3306===>端口號； Lee_My===>數據庫的名字
String user = "root";// 用戶名
String pwd = "123";// 密碼
con = DriverManager.getConnection(url, user, pwd);// 打開數據庫
具體實例看以下代碼：
package com.fs.test;
//import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import javax.swing.JOptionPane;
import com.fs.po.Stu;
public class Test {
private Connection getCon() {// 寫1個連接
數據庫的方法，需要兩步
Connection con = null;
// (1) 加載驅動
try {
Class.forName("org.gjt.mm.mysql.Driver");
// (2)connect連接
數據庫 "jdbc:mysql://192.168.1.17:3306/Lee_My";
String url = "jdbc:mysql://localhost:3306/fs_service";
String user = "root";
String pwd = "123";
// 類 DriverManager：管理1組 JDBC 驅動程序的基本服務。
con = DriverManager.getConnection(url, user, pwd);
// getConnection(String url, String user, String password)
// 試圖建立到給定
數據庫 URL 的連接。DriverManager 試圖從已注冊的 JDBC 驅動程序集當選擇1個適當的驅動程序。
} catch (Exception e) {
e.printStackTrace();
}
return con;
}
// insert
private void add() throws Exception {
/** Connection 與特定
數據庫的連接（會話）。在連接上下文中履行 SQL 語句并返回結果。*/
Connection con = this.getCon();// 連接
數據庫
Statement st = con.createStatement();// Statement 用于履行靜態 SQL 語句并返回它所生成結果的對象。
//接口 Connection 中的 createStatement()方法的作用是：創建1個 Statement 對象來將 SQL 語句發送到
數據庫。
int no = 0;
no = no + st.executeUpdate("insert into stu(name, age, xueHao)values('XiaoMing1', 23, 7)");
no = no + st.executeUpdate("insert into stu(name, age, xueHao)values('XiaoMing2', 24, 8)");
// 接口 Statement 中的 executeUpdate(String sql)方法的作用： 履行給定 SQL 語句，
// 該語句可能為 INSERT、UPDATE 或 DELETE 語句，或不返回任何內容的 SQL 語句（如 SQL DDL 語句）。
con.close();// 關閉流
JOptionPane.showMessageDialog(null, no);// 告知用戶某事已產生，彈出1個對話框，對話框中顯示的消息為no
}
// delete
private void delete() throws Exception {// 同 add()方法
Connection con = this.getCon();
Statement st = con.createStatement();
int no = 0;
no = no + st.executeUpdate("delete from stu where id>1");
con.close();
JOptionPane.showMessageDialog(null, no);
}
private void update() throws Exception {// 同 add()方法
Connection con = this.getCon();
Statement st = con.createStatement();
int no = 0;
no = no + st.executeUpdate("update stu set name='xiaoMing', age=30 where id>1");
con.close();
JOptionPane.showMessageDialog(null, no);
}
private List<Stu> select() throws SQLException {// 創1個集合List保存查詢出來的記錄
Connection con = this.getCon();// 連接
數據庫
Statement st = con.createStatement();// Statement 用于履行靜態 SQL 語句并返回它所生成結果的對象。
// 接口 Statement 中的executeQuery（sql） 方法履行給定的 SQL 語句，該語句返回單個 ResultSet 對象。
// 返回：包括給定查詢所生成數據的 ResultSet 對象；永久不能為 null
ResultSet r = st.executeQuery("select id, name, age, xueHao from stu");
List<Stu> list = new ArrayList<Stu>();// 創建1個ArrayList對象
// 用while循環遍歷出各條記錄
while(r.next()) {// r.next()指向下1條記錄，最開始指向的是字段，逐次往下移
int id = r.getInt(1);// 輸出id列，即表中第1列
String name = r.getString(2);// 輸出name列，即表中第2列
int age = r.getInt(3);// 輸出age列，即表中第3列
int xueHao = r.getInt(4);// 輸出xueHao列，即表中第4列
list.add(new Stu(id, name, age, xueHao));// 1條記錄就是1個對象，所以把各條記錄new個對象裝入ArrayList集合中
}
con.close();// 關閉流
return list;// 返回list集合
}
public static void main(String[] args) throws Exception {
List<Stu> list = new Test().select();
for (Stu stu : list) {// 集合遍歷
System.out.println(stu.toString());
}
}
}
生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈
