(一)創建工程,引入驅動包
在下圖目錄中可以找到驅動包ORACLE的JDBC驅動包,拷貝到工程即可使用


創建java工程waterboss,建立lib文件夾,將ojdbc.jar拷貝到此文件夾,然后add build path


(二)BaseDao
我們通常編寫BaseDao負責加載驅動,獲取數據庫連接,關閉資源,代碼如下:
package cn.itcast.waterboss.dao;
import java.sql.SQLException;
/**
* 基本數據訪問類
* @author Administrator
*
*/
public class BaseDao {
//加載驅動
static {
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/**
* 獲取數據庫連接
* @return
* @throws SQLException
*/
public static java.sql.Connection getConnection() throws SQLException {
return java.sql.DriverManager.getConnection(
"jdbc:oracle:thin:@192.168.80.10:1521:orcl",
"wateruser",
"itcast"
);
}
/**
* 關閉資源
* @param rs
* @param stmt
* @param conn
*/
public static void closeAll(
java.sql.ResultSet rs,
java.sql.Statement stmt,
java.sql.Connection conn
) {
//關閉結果集
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//關閉執行對象
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//關閉執行對象
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
JDBC驅動為:
oracle.jdbc.OracleDriver
連接字符串( 瘦連接 ):
jdbc:oracle:thin:@虛擬機的 IP:1521:orcl
(三)業主增刪改代碼編寫
1.創建實體類
package cn.itcast.waterboss.entity;
import java.util.Date;
/**
* 業主實體類
* @author Administrator
*
*/
public class Owners {
private Long id; //編號
private String name; //業主名稱
private Long addressid; //地址編號
private String housenumber; //門牌號
private String watermeter; //水表編號
private Date adddate; //登記日期
private Long ownertypeid; //業主類型 ID
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Long getAddressid() {
return addressid;
}
public void setAddressid(Long addressid) {
this.addressid = addressid;
}
public String getHousenumber() {
return housenumber;
}
public void setHousenumber(String housenumber) {
this.housenumber = housenumber;
}
public String getWatermeter() {
return watermeter;
}
public void setWatermeter(String watermeter) {
this.watermeter = watermeter;
}
public Date getAdddate() {
return adddate;
}
public void setAdddate(Date adddate) {
this.adddate = adddate;
}
public Long getOwnertypeid() {
return ownertypeid;
}
public void setOwnertypeid(Long ownertypeid) {
this.ownertypeid = ownertypeid;
}
}
2.創建Dao類實現增刪改
package cn.itcast.waterboss.dao;
import cn.itcast.waterboss.entity.Owners;
import java.sql.SQLException;
/**
* 業主數據訪問類
* @author Administrator
*
*/
public class OwnersDao {
/**
* 新增業主
* @param owners
*/
public static void add(Owners owners) {
java.sql.Connection conn = null;
java.sql.PreparedStatement stmt = null;
try {
conn = BaseDao.getConnection();
stmt =
conn.prepareStatement("insert into T_OWNERS
values(?,?,?,?,?,?,?)");
stmt.setLong(1, owners.getId());
stmt.setString(2, owners.getName());
stmt.setLong(3, owners.getAddressid());
stmt.setString(4, owners.getHousenumber());
stmt.setString(5, owners.getWatermeter());
stmt.setDate(6, new java.sql.Date(owners.getAdddate().getTime()));
stmt.setLong(7, owners.getOwnertypeid());
stmt.execute();
} catch (SQLException e) {
e.printStackTrace();
} finally {
BaseDao.closeAll(null, stmt, conn);
}
}
/**
* 修改業主
* @param owners
*/
public static void update(Owners owners) {
java.sql.Connection conn = null;
java.sql.PreparedStatement stmt = null;
try {
conn = BaseDao.getConnection();
stmt =
conn.prepareStatement(
"update T_OWNERS set
name=?,addressid=?,housenumber=?," +
"watermeter=?,adddate=?, ownertypeid=? where
id=?"
);
stmt.setString(1, owners.getName());
stmt.setLong(2, owners.getAddressid());
stmt.setString(3, owners.getHousenumber());
stmt.setString(4, owners.getWatermeter());
stmt.setDate(5, new java.sql.Date(owners.getAdddate().getTime()));
stmt.setLong(6, owners.getOwnertypeid());
stmt.setLong(7, owners.getId());
stmt.execute();
} catch (SQLException e) {
e.printStackTrace();
} finally {
BaseDao.closeAll(null, stmt, conn);
}
}
/**
* 刪除業主
* @param owners
*/
public static void delete(Long id) {
java.sql.Connection conn = null;
java.sql.PreparedStatement stmt = null;
try {
conn = BaseDao.getConnection();
stmt = conn.prepareStatement("delete from T_OWNERS where
id=?");
stmt.setLong(1, id);
stmt.execute();
} catch (SQLException e) {
e.printStackTrace();
} finally {
BaseDao.closeAll(null, stmt, conn);
}
}
}
版權聲明:本文內容由互聯網用戶自發貢獻,該文觀點僅代表作者本人。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。如發現本站有涉嫌抄襲侵權/違法違規的內容, 請發送郵件至 舉報,一經查實,本站將立刻刪除。
發表評論
請登錄后評論...
登錄后才能評論