คัดลอกรหัสรหัสดังต่อไปนี้:
แพ็คเกจ sns.team6.util;
นำเข้า java.sql.Connection;
นำเข้า java.sql.DriverManager;
นำเข้า java.sql.PreparedStatement;
นำเข้า java.sql.ResultSet;
นำเข้า java.sql.SQLException;
-
* คลาสเครื่องมือสำหรับการเชื่อมโยงกับฐานข้อมูล
-
* @ผู้เขียน Xu Rui
-
-
DBHelper ระดับสาธารณะ {
// เส้นทางไดรเวอร์ mysql
ไดรเวอร์สตริงสุดท้ายคงที่ส่วนตัว = "com.mysql.jdbc.Driver";
// เส้นทางการเชื่อมต่อฐานข้อมูล
url สตริงสุดท้ายแบบคงที่ส่วนตัว = "jdbc:mysql://localhost:3306/snsteam6";
-
* วัตถุเพื่อเชื่อมต่อกับฐานข้อมูล
-
* @กลับ
-
getConnection การเชื่อมต่อแบบคงที่สาธารณะ () {
การเชื่อมต่อการเชื่อมต่อ = null;
พยายาม {
Class.forName(คนขับ);
conn = DriverManager.getConnection (url, "root", "root");
} จับ (ข้อยกเว้นจ) {
e.printStackTrace();
-
กลับคอน;
-
-
* ปิดทรัพยากรที่เปิดอยู่
-
* @param conn
* @param pst
* @param ครั้งแรก
-
โมฆะคงที่สาธารณะ closeInfo (การเชื่อมต่อ conn, ReadyStatement pst,
ชุดผลลัพธ์แรก) {
พยายาม {
ถ้า (แรก != null) {
rst.ปิด();
แรก = โมฆะ;
-
ถ้า (pst != null) {
pst.ปิด();
PST = โมฆะ;
-
ถ้า (conn != null) {
conn.ปิด();
คอนน์ = โมฆะ;
-
} จับ (ข้อยกเว้นจ) {
e.printStackTrace();
-
-
-
* รับวัตถุชุดผลลัพธ์
-
* @param sql
* @param พารามส์
* @กลับ
-
ชุดผลลัพธ์ ResultSet แบบคงที่สาธารณะ (สตริง sql, พารามิเตอร์วัตถุ []) {
//อ็อบเจ็กต์ลิงก์ฐานข้อมูล
การเชื่อมต่อการเชื่อมต่อ = null;
//วัตถุการดำเนินการฐานข้อมูล
คำสั่งที่เตรียมไว้ pst = null;
//วัตถุผลลัพธ์
ResultSet rst = null;
พยายาม {
//อ็อบเจ็กต์ลิงก์ฐานข้อมูล
conn = DBHelper.getConnection();
//วัตถุการดำเนินการฐานข้อมูล
pst = conn.prepareStatement(sql);
// พิจารณาว่ามีพารามิเตอร์หรือไม่
ถ้า (params != null && params.length > 0) {
สำหรับ (int i = 0; i < params.length; i++) {
//กำหนดค่าให้กับออบเจ็กต์การดำเนินการ
pst.setObject(i + 1, พารามิเตอร์ [i]);
-
-
// รับวัตถุผลลัพธ์
rst = pst.executeQuery();
} จับ (SQLException e) {
แรก = โมฆะ;
e.printStackTrace();
-
กลับก่อน;
-
-
* รับวัตถุผลลัพธ์ที่เพิ่มเข้ามา
-
* @param sql
* @param พารามส์
* @กลับ
-
ผลลัพธ์บูลีนคงที่สาธารณะ (สตริง sql, พารามิเตอร์วัตถุ []) {
ธงบูลีน = เท็จ;
//อ็อบเจ็กต์ลิงก์ฐานข้อมูล
การเชื่อมต่อการเชื่อมต่อ = null;
//วัตถุการดำเนินการฐานข้อมูล
คำสั่งที่เตรียมไว้ pst = null;
พยายาม {
//อ็อบเจ็กต์ลิงก์ฐานข้อมูล
conn = DBHelper.getConnection();
//วัตถุการดำเนินการฐานข้อมูล
pst = conn.prepareStatement(sql);
// พิจารณาว่ามีพารามิเตอร์หรือไม่
ถ้า (params != null && params.length > 0) {
สำหรับ (int i = 0; i < params.length; i++) {
//กำหนดค่าให้กับออบเจ็กต์การดำเนินการ
pst.setObject(i + 1, พารามิเตอร์ [i]);
-
-
// รับวัตถุผลลัพธ์ซึ่งเป็นประเภท int ซึ่งระบุจำนวนแถวที่ดำเนินการสำเร็จ
แถว int = pst.executeUpdate();
ถ้า (แถว > 0) {
// ถ้ามากกว่า 0 แสดงว่าดำเนินการสำเร็จ
ธง = จริง;
-
} จับ (SQLException e) {
ธง = เท็จ;
e.printStackTrace();
-
ธงส่งคืน;
-
-