數據庫操作方法總結

2019-11-14 22:33:42

字體：大中小

來源：轉載

供稿：網友

數據庫操作方法總結

解決辦法：

端口號錯誤。

初學者可以這么搞，堅持半年，效果顯著。

釋放資源的時候
我們需要從外往里面依次釋放，與你聲明的時候相反。就像人們穿衣服一樣，然后脫衣服，效果類似。
有些sql語句沒有參數，怎么辦
遍歷數組，需要判斷，有些語句不需要賦值。所以需要先判斷是否需要賦值，所以先判斷是否為空。
參考資料：http://zhidao.baidu.com/link?url=wT5zIOjpPQzE3pfAjPC-DZAlnEAO89O2ihgLT8SpFCKaXtktcBELHO5iRKeasUkMF8Wt0W__nhdMjK6-3i4-J_
分層
系統架構的解耦，主要是為了今后的擴展。因為今天的項目需求變更多，項目大。
表示層：jsf structs2.0 門窗
框架： sPRing 骨骼
持久層：hibernate
層與層之間是松耦合的。
三層：
Web層， service層， DAO層表示層，服務層，數據訪問層
Web層調用service層；服務層調用dao層。
必須先有，才能調用。所以，編程從后往前。
生產與使用分離。想象一下主板與內存條的關系。
無緣無故多搞出來一層，其目的是上面一層DAO層幾乎不怎么動，而service層只需調用即可。也就是說，我們多了一個interface層。
訪問數據庫的工具在util中，我如何在impl中使用工具
1. 實例化一個對象
2. 繼承工具類，繼承過來就是我的，我就可以直接使用了。

錯誤：

你在程序中操作的長度大于在數據庫當中的長度

因為我在設計數據庫表的時候，sex的長度只有1，而我在程序里面賦值為男，為兩個字符。所以，長度不一致。

當然，還有其他一些錯誤：比如長度不一致，順序不一致。？與 param必須嚴格一致。一個？對應一個變量。一個參數，這樣才可以。

新聞欄目添加、修改、查詢（）、刪除（新聞欄目下面有很多新聞內容，先刪除內容，再刪除欄目）

下面講講規范：

一般我們開發分為幾層。DAO層一般放接口

下面以UserInfo這張表為例，講講MVC金典操作。

首先建立實體類
實體類的建立，依據數據庫表中的字段而來的。下面是這些數據庫表中的字段名。
然后，通過eclipse 生成getter 和 setter 方法。程序如下面所示。

package com.buu.news.day3.entity;
public class UserInfo {
private String userID;
private String UserRealName;
private String sex;
private String birth;
private String famillyaddress;
private String email;
private String tel;
private String userLoginName;
private String regDate;
private String userPasWord;
private String conform;
private String flag;
public String getUserID() {
return userID;
}
public void setUserID(String userID) {
this.userID = userID;
}
public String getUserRealName() {
return UserRealName;
}
public void setUserRealName(String userRealName) {
UserRealName = userRealName;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String getBirth() {
return birth;
}
public void setBirth(String birth) {
this.birth = birth;
}
public String getFamillyaddress() {
return famillyaddress;
}
public void setFamillyaddress(String famillyaddress) {
this.famillyaddress = famillyaddress;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public String getTel() {
return tel;
}
public void setTel(String tel) {
this.tel = tel;
}
public String getUserLoginName() {
return userLoginName;
}
public void setUserLoginName(String userLoginName) {
this.userLoginName = userLoginName;
}
public String getRegDate() {
return regDate;
}
public void setRegDate(String regDate) {
this.regDate = regDate;
}
public String getUserPasword() {
return userPasword;
}
public void setUserPasword(String userPasword) {
this.userPasword = userPasword;
}
public String getConform() {
return conform;
}
public void setConform(String conform) {
this.conform = conform;
}
public String getFlag() {
return flag;
}
public void setFlag(String flag) {
this.flag = flag;
}
}
1. 建立UserInfo這個表的接口層，定義一些個操作，我們稱之為用戶操作接口。主要完成用戶登錄、刪除、修改、查詢和插入新的用戶等操作。
  操作如下：
package com.buu.news.day3.dao;
import java.sql.ResultSet;
import com.buu.news.day3.entity.UserInfo;
/*
* 用戶操作接口
* 1、登錄操作
* 2、刪除操作
* 3、修改操作
* 4、查詢操作
* 5、插入新的用戶操作
*/
public interface UserDao {
//需要先定義一個封裝用戶的實體類
/*
*1、用戶登錄操作
* 參數：用戶對象
* 返回值：true :登錄成功
* false:登錄失敗
*/
public boolean userLogin(UserInfo user);
/*
*2、刪除用戶操作
* 參數：用戶對象
* 返回值：int : 0:不成功
* !0 :成功
*/
public int userDelete(UserInfo user);
/*
*3、用戶修改
* 參數：用戶對象
* 返回值：int : 0:不成功
* !0 :成功
*/
public int userUpdate(UserInfo user);
/*
*4、用戶插入
* 參數：用戶對象
* 返回值：int : 0:不成功
* !0 :成功
*/
public int userInsert(UserInfo user);
/*
*5、用戶查詢
* 參數：用戶對象
* 返回值：resultset集合
*
*/
public ResultSet userSelect(UserInfo user);
}
1. 建立UserServiceDao的接口層，此層與上面的代碼一樣。只是增加了一個接口而已。
2. 建立UserDaoImpl ,此類是UserDao的實現類，實現UerDao接口。
  代碼如下：（里面有增刪改查）
package com.buu.news.day3.dao.impl;
import java.sql.ResultSet;
import com.buu.news.day3.dao.UserDao;
import com.buu.news.day3.entity.UserInfo;
import com.buu.news.day3.util.ConnDB;
public class UserDaoImpl extends ConnDB implements UserDao {
//public ConnDB conn = new ConnDB();
public int userDelete(UserInfo user) {
// TODO Auto-generated method stub
String sql = "delete from userInfo where userID = ?"; //占位符？
String[] param = {user.getUserID()}; //調用方法必須傳數組
int rtn = this.executeSQL(sql, param);
if(rtn > 0)
System.out.println("刪除成功");
else
System.out.println("刪除失敗");
return rtn;
}
public int userInsert(UserInfo user) {
// TODO Auto-generated method stub
String sql = "insert into userInfo values(?,?,?,?,?,?,?,?,?,?,?)";
String[] param = {user.getUserRealName(),user.getSex(),user.getBirth(),user.getFamillyaddress(),user.getEmail(),user.getTel(),user.getUserLoginName(),user.getRegDate(),user.getUserPasword(),user.getConform(),user.getFlag()};
int rtn = this.executeSQL(sql, param);
if(rtn > 0)
System.out.println("插入成功");
else
System.out.println("插入失敗");
return rtn;
}
public boolean userLogin(UserInfo user) {
// TODO Auto-generated method stub
return false;
}
public ResultSet userSelect(UserInfo user) {
// TODO Auto-generated method stub
String sql = "select * from userInfo where userID = ?";
String[] param = {user.getUserID()};
ResultSet rs = this.executeSelectSQL(sql,param);
if(rs != null)
System.out.println("查詢成功");
else
System.out.println("查詢失敗");
return rs;
}
public int userUpdate(UserInfo user) {
// TODO Auto-generated method stub
String sql = "update userInfo set userRealName = ?,sex = ?,birth = ?,fimallyAddress = ?,Email=?";
sql += ",Tel=?,userLoginName=?,regDate=?,userPassword=?,confirm1=?,flog=? where userID=?";
String[] param = {user.getUserRealName(),user.getSex(),user.getBirth(),user.getFamillyaddress(),user.getEmail(),user.getTel(),user.getUserLoginName(),user.getRegDate(),user.getUserPasword(),user.getConform(),user.getFlag(),user.getUserID()};
int rtn = this.executeSQL(sql, param);
if(rtn > 0)
System.out.println("更新成功");
else
System.out.println("更新失敗");
return rtn;
}
}
其中，有幾個關鍵的地方，需要提一下
關鍵地方一：this.executeSelectSQL(sql,param); 和 this.executeSQL(sql, param); 這兩句是增刪改與查分家的地方。我們可以定義工具類來實現頂層操作。
這些頂層操作是工具，是可以重復利用的代碼邏輯。
關鍵地方二：為啥用this，其實這里面我們完全可以用類的實例化，然后再調用對象.方法來實現，這里卻用到了上面的形式。我們在實現此接口的同事，還可以
繼承工具類，這樣的話，我們就可以不用實例化了，這樣的話，代碼量可以進一步減少。健壯性又有所提高。
1. 工具類 ConnDB
  代碼如下：
package com.buu.news.day3.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/*
* 數據庫基本操作
* 1、獲取連接對象
* 2、釋放相關資源
* 3、數據庫增刪改查
*/
public class ConnDB {
//定義數據連接字符串，訪問數據庫用戶名和密碼
public final static String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
public final static String url = "jdbc:sqlserver://localhost:1433;DataBaseName=NewsSystem";
public final static String dbName = "sa";
public final static String dbPa = "123456";
/*1、獲取數據庫連接對象
* 返回值：connection對象
*/
public Connection getConn()
{
Connection conn = null;
try {
Class.forName(driver);
conn = DriverManager.getConnection(url, dbName, dbPa);
System.out.println("數據庫連接成功");//提示的
} catch (Exception e) { //為了使拋出的異常減少，拋出ClassNotFound的父類即可
// TODO Auto-generated catch block
e.printStackTrace();
}//必須要有異常處理，增加程序的健壯性
return conn;
}
/*釋放連接數據庫的所有資源
* 資源包括：連接對象connection，statement對象，preparement對象，resultset對象
*/
public void closeAll(Connection conn, Statement stmt, PreparedStatement pstmt, ResultSet rs)
{
try {
if(rs!=null)
rs.close();
if(pstmt!=null)
pstmt.close();
if(stmt!=null)
stmt.close();
if(conn!=null)
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/*
* 執行更新操作：插入、修改、刪除（會有成功和失敗）
* 參數：sql語句; param:sql賦值參數
* 返回值：int類型。sql語句對數據庫影響的行數
* 0：含義：插入、修改、刪除失敗
*/
public int executeSQL(String sql, String[] param)
{
Connection conn = null;
PreparedStatement pstmt = null;
int rtn = 0;
//處理sql語句，執行sql語句
conn = this.getConn();// 里面已經有鏈接了
try {
pstmt = conn.prepareStatement(sql);//sql語句只有一條，但賦的值不只一條，避免重復造輪子
if(param != null)
{
for(int i = 0; i < param.length; ++i)
{
pstmt.setString(i+1, param[i]);//為預編譯的sql語句賦參數，語句下標從1開始。（數組里面的個數就是 sql語句中占位符的個數，不過sql語句里面的下標從1開始，數組下標從0開始）
}
}
//執行sql語句
rtn = pstmt.executeUpdate(); //只有他返回int類型參數
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rtn;
}
/*
* 執行查詢操作
* 參數：sql語句; param:sql賦值參數
* 返回值：ResultSet類型
*
*/
public ResultSet executeSelectSQL(String sql, String[] param)
{
Connection conn = null;
PreparedStatement pstmt = null;
//處理sql語句，執行sql語句
conn = this.getConn();// 里面已經有鏈接了
ResultSet rtn = null;
try {
pstmt = conn.prepareStatement(sql);//sql語句只有一條，但賦的值不只一條，避免重復造輪子
if(param != null)
{
for(int i = 0; i < param.length; ++i)
{
pstmt.setString(i+1, param[i]);//為預編譯的sql語句賦參數，語句下標從1開始。
}
}
//執行sql語句
rtn = pstmt.executeQuery(); //只有他返回int類型參數
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rtn;
}
}
1. 創建數據庫訪問接口，這里為UserServiceDaoImpl ,是UserServiceDao接口類的實現。
  程序里面只是一個接口而已，先實例化，然后返回一些個值。
package com.buu.news.day3.service.impl;
import java.sql.ResultSet;
import com.buu.news.day3.dao.UserDao;
import com.buu.news.day3.dao.impl.UserDaoImpl;
import com.buu.news.day3.entity.UserInfo;
import com.buu.news.day3.service.UserServiceDao;
public class UserServiceDaoImpl implements UserServiceDao {
//創建數據庫訪問接口
private UserDao userdao = new UserDaoImpl();
public int userDelete(UserInfo user) {
// TODO Auto-generated method stub
int rtn = userdao.userDelete(user);
return rtn;
}
public int userInsert(UserInfo user) {
// TODO Auto-generated method stub
int rtn = userdao.userInsert(user);
return rtn;
}
public boolean userLogin(UserInfo user) {
// TODO Auto-generated method stub
boolean rtn = userdao.userLogin(user);
return rtn;
}
public ResultSet userSelect(UserInfo user) {
// TODO Auto-generated method stub
ResultSet rs = userdao.userSelect(user);
return rs;
}
public int userUpdate(UserInfo user) {
// TODO Auto-generated method stub
int rtn = userdao.userUpdate(user);
return rtn;
}
}
以上搞定了業務邏輯層調用數據訪問層，后面開始搞表示層調用業務邏輯層。