Database.properties
การคัดลอกรหัสมีดังนี้:
jdbc.driver_class = oracle.jdbc.driver.oracledriver
jdbc.connection.url = jdbc: Oracle: Thin: @localhost: 1521: ORCL
jdbc.connection.username = Scott
jdbc.connection.password = tiger
configmanager.java
การคัดลอกรหัสมีดังนี้:
นำเข้า java.io.ioException;
นำเข้า Java.io.InputStream;
นำเข้า java.util.properties;
// เครื่องมือสำหรับการอ่านไฟล์กำหนดค่า (ไฟล์คุณสมบัติ)
configmanager คลาสสาธารณะ {
configmanager ส่วนตัวแบบคงที่ configManager;
// properties.load (inputStream);
คุณสมบัติคุณสมบัติคงที่ส่วนตัว;
// อ่านไฟล์การกำหนดค่าเมื่อสร้างคลาสเครื่องมือ
Private ConfigManager () {
String configFile = "database.properties";
คุณสมบัติ = คุณสมบัติใหม่ ();
InputStream คือ = configManager.class.getClassLoader ()
.GetResourceasStream (configfile);
พยายาม {
// อ่านไฟล์กำหนดค่า
Properties.load (IS);
is.close ();
} catch (ioexception e) {
E.PrintStackTrace ();
-
-
// ตั้งค่าหมายเลขอินสแตนซ์ผ่านโหมด Singleton
Public Static ConfigManager GetInstance () {
if (configManager == null) {
configManager = new configManager ();
-
Return ConfigManager;
-
// รับค่าที่สอดคล้องกันผ่านคีย์
สตริงสาธารณะ getString (คีย์สตริง) {
คืนคุณสมบัติ. getProperty (คีย์);
-
-
basedao.java
การคัดลอกรหัสมีดังนี้:
นำเข้า java.sql.connection;
นำเข้า java.sql.drivermanager;
นำเข้า java.sql.preparedStatement;
นำเข้า java.sql.resultset;
นำเข้า java.sql.sqlexception;
นำเข้า java.sql.statement;
นำเข้า com.book.util.ConfigManager;
// คลาสพื้นฐาน: คลาสทั่วไปสำหรับการดำเนินการฐานข้อมูล
คลาสสาธารณะที่ใช้ {
การเชื่อมต่อที่ได้รับการป้องกัน Conn;
ได้รับการปกป้อง PreparedStatement PS;
คำแถลงที่ได้รับการป้องกัน stmt;
ชุดผลลัพธ์ที่ได้รับการป้องกัน RS;
// รับการเชื่อมต่อฐานข้อมูล
บูลีนสาธารณะ getConnection () {
// // อ่านข้อมูลการกำหนดค่า
String driver = configManager.getInstance (). getString (
"jdbc.driver_class");
string url = configmanager.getInstance (). getString (
"jdbc.connection.url");
String username = configManager.getInstance (). getString (
"jdbc.connection.username");
สตริงรหัสผ่าน = configManager.getInstance (). getString (
"jdbc.connection.password");
// โหลดไดรเวอร์ JDBC
พยายาม {
class.forname (ไดรเวอร์);
// สร้างการเชื่อมต่อกับฐานข้อมูล
conn = drivermanager.getConnection (URL, ชื่อผู้ใช้, รหัสผ่าน);
} catch (classnotFoundException e) {
กลับเท็จ;
} catch (sqlexception e) {
กลับเท็จ;
-
กลับมาจริง;
-
// วิธีการทั่วไปสำหรับการเพิ่มการลบและการแก้ไข
public int executeUpdate (String SQL, Object [] params) {
int updaterows = 0;
getConnection ();
พยายาม {
ps = conn.prepareStatement (SQL);
// กรอกตำแหน่งในตัวยึด
สำหรับ (int i = 0; i <params.length; i ++) {
ps.setObject (i + 1, params [i]);
System.out.println (i + 1 + "---" + params [i]);
-
System.out.println (SQL);
updaterows = ps.executeUpdate ();
} catch (sqlexception e) {
E.PrintStackTrace ();
-
ส่งคืนอัพเดท
-
// คำถาม
Public Resultset ExecutesQl (String SQL, Object [] params) {
getConnection ();
พยายาม {
ps = conn.prepareStatement (SQL);
// กรอกตำแหน่งในตัวยึด
สำหรับ (int i = 0; i <params.length; i ++) {
ps.setObject (i + 1, params [i]);
-
rs = ps.executeQuery ();
} catch (sqlexception e) {
E.PrintStackTrace ();
-
กลับอาร์เอส;
-
// ปิดทรัพยากร
โมฆะสาธารณะ CloseAll () {
พยายาม {
ถ้า (rs! = null) {
Rs.close ();
-
if (stmt! = null) {
stmt.close ();
-
ถ้า (ps! = null) {
ps.close ();
-
if (conn! = null) {
conn.close ();
-
} catch (sqlexception e) {
E.PrintStackTrace ();
-
-
-