2. 程式人生 > >初學JDBC(四)-使用Preparedstatement介面實現增刪改操作

初學JDBC(四)-使用Preparedstatement介面實現增刪改操作

阿新 • • 發佈：2019-01-01

      上一篇部落格中我講了使用Statement對資料庫中的表內容進行增刪改操作，先講了原始的增刪改即每次增加刪除修改都需要載入資料庫驅動，連線資料庫，執行SQL語句，關閉資料庫，這樣的話，程式碼的重複量有些大，程式碼冗餘比較明顯，後來進行修改，運用了Java繼承封裝和多型的思想，對原來的增刪改程式碼進行了優化，這一篇部落格我來說說用PreparedStatement介面實現對資料庫表內容的增刪改操作，在現實的開發中也常用PreparedStatement介面而不是Statement介面進行增刪改操作：使用PreparedStatement對於程式碼的可維護性和可讀性提高了；使用PreparedStatement盡最大可能提高效能；最重要的一點是極大地提高了安全性。(PS今天上完課頭有些暈暈乎乎，狀態不是很好，可是閒來無事，就又來刷部落格了，如有錯誤請原諒並指出來哭

)。

      PreparedStatement是Statement介面的子介面，屬於預處理操作，與直接使用Statement不同，PreparedStatement在操作時，是預先在資料表中準備好了一條SQL語句，但是此SQL語句的具體內容暫時不設定，而是之後在進行設定。

      PreparedStatement介面的技術原理:

      PreparedStatement例項包含已編譯的SQL語句，SQL語句可能包含1個，2個或多個輸入的值，這些值未被明確指定在SQL語句中用？作為佔位符代替，之後執行SQL語句之前要用setXXX()方法對值進行寫入。

      PreparedStatement物件比Statement物件的執行速度要快，因為PreparedStatement物件已經預編譯過了，因此需要多次執行的SQL語句也可以用PreparedStatement物件進行執行來加快執行速度。

      作為Statement的子類，PreparedStatement介面繼承了Statement的所有功能。另外它還整合一整套getXXX()和setXXX()方法，用於對值得獲取和輸入設定。同時，它還修改了三個方法execute、executeQuery、executeUpdate使它們不需要引數。這些方法的Statement形式，不應該再用於PreparedStatement物件。

      PreparedStatement中的方法摘要：

      1：executeQuery():在此PreparedStatement物件中執行SQL語句，並返回該查詢生成的ResultSet物件。

      2：executeUpdate():在此PreparedStatement物件中執行SQL語句，該語句必須是一個SQL資料操作語言(Date Manipulation Language，DML)語句，比如insert、update、delete語句；或者是無返內容的SQL語句，比如DDL語句。

      3：execute():在此PreparedStatement物件中執行SQL語句，該語句可以是任何種類的SQL語句。

      4：getMetaData():獲取包含有關ResultSet物件列資訊的ResultSetMetaData物件，ResultSet物件將在此執行PreparedStatement物件時返回。

      5：getParameterMetaData():獲取此PreparedStatement物件的引數的編號、型別和屬性。

      6：setAsciiStream(int parameterIndex, InputStream x, int longth):將指定引數設定為給定輸入流，該輸入流將具有給定位元組數。

      上面是一些常用額方法，如果想了解更多的方法請查閱JDK API文件，自行學習。

      例子：下面用PreparedStatement對t_employee表進行操作,直接運用Java的封裝繼承和多型思想進行實現，減少程式碼冗餘。建立表：

      create table t_employee(

            id int primary key auto_increment,

            userName varchar(20),

            salary decimal(6,2),

            job varchar(20),

            jobTypeId int

      )

package com.panli.dbutil;
/**
 * 連線資料庫
 */
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DbUtil {
	//資料庫驅動名字
	private static String jdbcName = "com.mysql.jdbc.Driver";
	//資料庫協議地址
	private static String dbUrl = "jdbc:mysql://localhost:3306/db_user";
	//資料庫使用者名稱
	private static String dbUser = "root";
	//資料庫密碼
	private static String dbPassword = "123456";
	
	
	/**
	 * 獲取連線
	 * @return
	 * @throws Exception
	 */
	public static Connection getCon() throws Exception{
		Class.forName(jdbcName);
		Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
		return conn;
	}
	
	/**
	 * 關閉連線
	 * @param stmt
	 * @param conn
	 * @throws Exception
	 */
	public static void close(Statement stmt,Connection conn) throws Exception{
		if(stmt!=null){
			stmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	/**
	 * 關閉連線
	 * @param cstmt
	 * @param conn
	 * @throws Exception
	 */
	public static void close(CallableStatement cstmt, Connection conn) throws Exception{
		if(cstmt!=null){
			cstmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	
	/**
	 * 關閉連線
	 * @param pstmt
	 * @param conn
	 * @throws SQLException
	 */
	public static void close(PreparedStatement pstmt, Connection conn) throws SQLException{
		if(pstmt!=null){
			pstmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	
	/**
	 * 過載關閉方法
	 * @param pstmt
	 * @param conn
	 * @throws Exception
	 */
	public void close(ResultSet rs,PreparedStatement pstmt, Connection conn) throws Exception{
		if(rs!=null){
			rs.close();
			if(pstmt!=null){
				pstmt.close();
				if(conn!=null){
					conn.close();
				}
				
			}
		}
		
	}
}

package com.panli.model;

import java.io.File;

/**
 * model包下的employee類,對每個欄位進行建模
 * @author Peter
 *
 */
public class Employee {
	private int id;
	private String userName;
	private double salary;
	private String job;
	private int jobTypeId;
	private File context;
	private File pic;
	
	/**
	 * 帶有6個引數的構造方法
	 * @param userName
	 * @param salary
	 * @param job
	 * @param jobTypeId
	 * @param context
	 * @param pic
	 */
	public Employee(String userName, double salary, String job, int jobTypeId,
			File context, File pic) {
		super();
		this.userName = userName;
		this.salary = salary;
		this.job = job;
		this.jobTypeId = jobTypeId;
		this.context = context;
		this.pic = pic;
	}

	/**
	 * 具有5個引數的構造方法
	 * @param userName
	 * @param salary
	 * @param job
	 * @param jobTypeId
	 * @param context
	 */
	public Employee(String userName, double salary, String job, int jobTypeId,
			File context) {
		super();
		this.userName = userName;
		this.salary = salary;
		this.job = job;
		this.jobTypeId = jobTypeId;
		this.context = context;
	}

	/**
	 * 預設的構造方法
	 */
	public Employee() {
		super();
		// TODO Auto-generated constructor stub
	}
	
	/**
	 * 帶一個引數的構造方法
	 * @param id
	 */
	public Employee(int id) {
		super();
		this.id = id;
	}

	/**
	 * 帶4個引數的構造方法
	 * @param userName
	 * @param salary
	 * @param job
	 * @param jobTypeId
	 */
	public Employee(String userName, double salary, String job, int jobTypeId) {
		super();
		this.userName = userName;
		this.salary = salary;
		this.job = job;
		this.jobTypeId = jobTypeId;
	}

	/**
	 * 帶引數的構造方法
	 * @param id
	 * @param userName
	 * @param salary
	 * @param job
	 * @param jobTypeId
	 */
	public Employee(int id, String userName, double salary, String job,
			int jobTypeId) {
		super();
		this.id = id;
		this.userName = userName;
		this.salary = salary;
		this.job = job;
		this.jobTypeId = jobTypeId;
	}

	/**
	 * 重寫toString()方法
	 */
	@Override
	public String toString() {
		return "Employee:[id=" + id + ", userName=" + userName + ", salary="
				+ salary + ", job=" + job + ", jobTypeId=" + jobTypeId + "]";
	}

	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public double getSalary() {
		return salary;
	}
	public void setSalary(double salary) {
		this.salary = salary;
	}
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	public int getJobTypeId() {
		return jobTypeId;
	}
	public void setJobTypeId(int jobTypeId) {
		this.jobTypeId = jobTypeId;
	}

	public File getContext() {
		return context;
	}

	public void setContext(File context) {
		this.context = context;
	}

	public File getPic() {
		return pic;
	}

	public void setPic(File pic) {
		this.pic = pic;
	}
	
}

package com.panli.dao;
/**
 * 對t_employee表進行增刪改操作
 */
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import com.panli.dbutil.DbUtil1;
import com.panli.model.Employee;

public class EmployeeDao {
	private static DbUtil dbUtil = new DbUtil();
	
	/**
	 * 對employee表新增資料
	 * @param employee
	 * @return
	 * @throws Exception
	 */
	public static int addData(Employee employee) throws Exception{
		Connection conn = dbUtil.getCon();
		String sql = "insert into t_employee values(null,?,?,?,?)";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setString(1, employee.getUserName());
		pstmt.setDouble(2, employee.getSalary());
		pstmt.setString(3, employee.getJob());
		pstmt.setInt(4, employee.getJobTypeId());
		int result = pstmt.executeUpdate();
		dbUtil.close(pstmt, conn);
		return result;
	}
	/**
	 * 對資料庫表內容進行修改
	 * @param employee
	 * @return
	 * @throws Exception 
	 */
	public static int updateData(Employee employee) throws Exception{
		Connection conn = dbUtil.getCon();
		String sql = "update t_employee set userName=?,salary=?,job=?,jobTypeId=? where id = ?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setString(1, employee.getUserName());
		pstmt.setDouble(2, employee.getSalary());
		pstmt.setString(3, employee.getJob());
		pstmt.setInt(4, employee.getJobTypeId());
		pstmt.setInt(5, employee.getId());
		int result = pstmt.executeUpdate();
		dbUtil.close(pstmt, conn);
		return result;
	}
	
	/**
	 * 對資料表內容刪除
	 * @param employee
	 * @return
	 * @throws Exception
	 */
	public static int deleteData(Employee employee) throws Exception{
		Connection conn = dbUtil.getCon();
		String sql = "delete from t_employee where id=? ";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1, employee.getId());
		int result = pstmt.executeUpdate();
		dbUtil.close(pstmt, conn);
		return result;
	}
	
}

package com.panli.test;
/**
 * 對使用PreparedStatement操作資料庫表內容的增刪改操作的測試
 */
import com.panli.dao.EmployeeDao;
import com.panli.model.Employee;

public class Test1 {
	private static EmployeeDao employeeDao = new EmployeeDao();
	
	public static void main(String[] args) throws Exception {
		/**
		 * 對資料庫表內容新增
		 */
		/*
		Employee employee = new Employee("川普", 100,"總統", 3);
		int result = employeeDao.addData(employee);
		if(result == 1){
			System.out.println("資料插入成功!");
		}else{
			System.out.println("資料插入失敗!");
		}
		*/
		/**
		 * 對資料表內容修改
		 */
		/*
		Employee employee = new Employee(3,"科比",800,"創業",2);
		int result = employeeDao.updateData(employee);
		if(result == 1){
			System.out.println("資料修改成功!");
		}else{
			System.out.println("資料修改失敗!");
		}
		*/
		
		Employee employee = new Employee(7);
		int result = employeeDao.deleteData(employee);
		if(result == 1){
			System.out.println("資料刪除成功!");
		}else{
			System.out.println("資料刪除失敗!");
		}
	}
}


相關推薦

初學JDBC(四)-使用Preparedstatement介面實現增刪改操作

      上一篇部落格中我講了使用Statement對資料庫中的表內容進行增刪改操作，先講了原始的增刪改即每次增加刪除修改都需要載入資料庫驅動，連線資料庫，執行SQL語句，關閉資料庫，這樣的話，程式碼的重複量有些大，程式碼冗餘比較明顯，後來進行修改，運用了Java繼承封裝

jdbc使用 PreparedStatement 介面實現更新資料操作

jdbc使用 PreparedStatement  介面實現更新資料操作 package chap04.sec03; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql

JDBC（三）——使用Statement介面對資料庫實現增刪改操作(3)

前面說到了使用Statement介面對資料庫進行增加資料操作； 現在我們來看一下修改操作和刪除操作； 其實基本原理是一樣的，就是sql語句有點不一樣； 1.修改操作； 我們新建一個update_sql類： package Month01.Day08.Demo02; import

JDBC（三）——使用Statement介面對資料庫實現增刪改操作(2)

上一篇部落格裡說到用Statement介面對資料庫實現增刪改操作，其中的sql語句是我們直接手寫的； 但在實際開發過程中，資料都是從前臺直接獲取的，而不是自己手動匯入的； 1.在新增圖書這個操作中，我們可以寫一個新增方法： //增加圖書的方法 private static int ad

JDBC（三）——使用Statement介面對資料庫實現增刪改操作(1)

1.Statement介面的引入：  Statement介面的作用： 用於執行靜態SQL語句並返回它所產生結果的物件； 2.使用Statement介面實現新增資料操作： 第一步：我們先將連線資料庫的程式碼封裝成一個工具類DbUtil；然後獲取資料庫連線； pack

複習：JDBC工具類並實現增刪改查

JDBC工具類 package bull01.JDBCbasis; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOExceptio

MyBatis編寫映射文件實現增刪改操作 附說明即源碼

其他 以及 clas insert utf close ini base void 1.看一下我們接口 package cn.bdqn.mybatis.dao; import org.apache.ibatis.annotations.Select; import c

JDBC之——PreparedStatement實現對資料庫的增刪改操作

一、PreparedStatement介面引入 PreparedStatement是Statement的子介面，屬於預處理操作，與直接使用Statement不同的是，PreparedStatement在操作時，是現在資料表中準備好了一條SQL語句，但是此SQL語句的具體內容

JDBC實現增刪改查

對資料庫進行增刪改操作的步驟： 1.通過Connection物件建立Statement，Statement的功能是向資料庫傳送SQL語句。 2.通過呼叫int executeUpdate(String sql)，它可以傳送DML和DDL 例項： Class.forName("com.

JSP + Servlet + JDBC + Mysql 實現增刪改查 課程管理系統

1.專案目錄結構 2.專案環境 Eclipse IDE  MYSQL  jdk tomcat jar包 3.資料庫相關配置 先建立一個course的資料庫名，然後在建立一個course的表 要注意將id欄位 自動遞增  4.原始碼    

使用PreparedStatement實現增刪改查

package com.power.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java

Java 利用 JDBC 連線 Sqlsever2012 實現 增刪改查

所需驅動檔案下載 http://download.csdn.net/detail/u012320991/9378730 資料表如下： 執行結果如下： 解決過程(預設SqlSever  已安裝並配置好)： 下載  JDBC 4.0 For SqlSever --->

JS元件系列——BootstrapTable+KnockoutJS實現增刪改查解決方案（四）：自定義T4模板快速生成頁面

前言：上篇介紹了下ko增刪改查的封裝，確實節省了大量的js程式碼。博主是一個喜歡偷懶的人，總覺得這些基礎的增刪改查效果能不能通過一個什麼工具直接生成頁面效果，啥程式碼都不用寫了，那該多爽。於是研究了下T4的語法，雖然沒有完全掌握，但是算是有了一個大致的瞭解，給需要自定義模板的園友們提供一個參考。於是乎有了今天

JDBC實現增刪改查、模糊查詢、分頁查詢、子查詢以及體現單例設計模式連線資料庫

package com.csdn.dao; import java.io.IOException; import java.io.InputStream; import java.util.Properties; /** * 單例模式 *

java基於jdbc操作mysql實現增刪改查日誌完整程式碼 不足之處歡迎留言指導

1、建立Java Project專案 2、匯入Jar包 3、建立資料庫 //根據實體類建立資料庫 4、建立實體類 (Bm.java) public class Bm { private int id; private String rq;

利用JDBC連線MySQL資料庫並實現增刪改查的程式碼示例

一、實現增刪改： 比較簡單： import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;

JDBC之java使用oracle中scott表實現增刪改查.1

Java與oracle資料庫連線—–JDBC Dao工具的建立 **寫部落格的目的及好處 1，為了把完成的知識點整理出來， 2，等同督促自己做學習總結 3，方便自己及同行者的閱覽 4，如有有心者，可以分享更精的知識

Java通過JDBC連線資料庫的三種方式！！！並對資料庫實現增刪改查

前言 java連線資料庫完整流程為： 1,獲得驅動(driver)，資料庫連線（url）,使用者名稱（username）,密碼（password）基本資訊的三種方式。 2,通過獲得的資訊完成JDBC實現連線資料庫。 注：連線前請匯入jar包，例：連線my

修改Haproxy文件配置，實現增刪改查

文件配置 str data bin 都是 [1] local def onf Haproxy 源文件 global log 127.0.0.1 local2 daemon maxconn 256 log 12

[python] 用pickle模塊實現“增刪改查”的簡易功能

python pyckle模塊 #!/usr/bin/env python2 #coding:utf-8 """ pickle的作用： 1：pickle.dump(dict,file)把字典轉為二進制存入文件. 2：pickle.load(file)把文件二進制內容轉為字典. """ im