jsp實現對mysql資料庫的操作

阿新 • • 發佈：2019-02-09

接上，在PersonDao.java中逐項完成方法。

PreparedStatement pmst;
Connection conn;
ResultSet rs;

增加資料：

public int addPerson(Person p) {
		int i = 0;
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "insert into users values(?,?,?,?,?)";
		
		try{
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.為佔位符傳值
			pmst.setInt(1, p.getId());
			pmst.setString(2, p.getName());
			pmst.setString(3, p.getSex());
			pmst.setInt(4, p.getAge());
			pmst.setString(5, p.getPhone());
			//5.執行sql語句
			i = pmst.executeUpdate();
			//釋放資源
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			e.printStackTrace();
		}	
		
		return i;
	}

在OaTest.java中進行測試：

@Test
	public void test2(){
		Person p = new Person(5,"李蓮英","男",20,"158121111");
		int i = dao.addPerson(p);
		if(i>0){
			System.out.println("插入成功！");
		}else{
			System.out.println("插入失敗！");
		}
	}

執行test2，插入成功：

事物：

將id設為主鍵後，如果表中已有該id的值，應該報錯。

在“com.xmx.oa.test”包下新建一個class“TrasctionDemo.java”

我們關閉事物自動提交，改為手動提交，並回滾：

@Test
	public void test1(){
		//1.與資料庫建立連線
		Connection conn = OaUtils.getConnection();
		//SQL語句
		String sql1 = "insert into users values(1,'愛好','男',20,'2424')";
		String sql2 = "insert into users values(3,'第三方','女',34,'2dsg')";
		String sql3 = "insert into users values(2,'的','男',31,'22fd4')";
		String sql4 = "insert into users values(4,'啊','女',80,'3dfs4')";
		
		try {
			//2.關閉事物自動提交
			conn.setAutoCommit(false);
			Statement smt = conn.createStatement();
			smt.executeUpdate(sql1);
			smt.executeUpdate(sql2);
			smt.executeUpdate(sql3);
			smt.executeUpdate(sql4);
			//3.手動提交
			conn.commit();
			System.out.println("插入成功！");
			//釋放資源
			smt.close();
			conn.close();
		} catch (Exception e) {
			//4.回滾到先前狀態
			System.out.println("出現異常，馬上回滾！");
			try {
				conn.rollback();
			} catch (Exception e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			e.printStackTrace();
		}
		
	}

這樣可以避免在多次操作中因一步錯誤而產生影響。

刪除單條資料：

public int deletePersonById(int id) {
		int i = 0;
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "delete from users where id=?";
		
		try{
			//關閉事物自動提交
			conn.setAutoCommit(false);
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.為佔位符傳值
			pmst.setInt(1, id);
			//4.執行sql語句
			i = pmst.executeUpdate();
			//手動提交
			conn.commit();
			//釋放資源
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			//回滾到先前狀態
			System.out.println("出現異常，馬上回滾！");
			try {
				conn.rollback();
			} catch (Exception e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			e.printStackTrace();
		}	
		
		return i;
	}

測試：

public void test3(){
		int i = dao.deletePersonById(5);
		if(i>0){
			System.out.println("刪除成功！");
		}else{
			System.out.println("刪除失敗！");
		}
	}

修改資料：

public int updatePerson(Person p) {
		int i = 0;
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "update users set name=?, sex=?, age=?, phone=? where id=? ";
		
		try{
			//關閉事物自動提交
			conn.setAutoCommit(false);
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.為佔位符傳值		
			pmst.setString(1, p.getName());
			pmst.setString(2, p.getSex());
			pmst.setInt(3, p.getAge());
			pmst.setString(4, p.getPhone());
			pmst.setInt(5, p.getId());
			//4.執行sql語句
			i = pmst.executeUpdate();
			//手動提交
			conn.commit();
			//釋放資源
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			//回滾到先前狀態
			System.out.println("出現異常，馬上回滾！");
			try {
				conn.rollback();
			} catch (Exception e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			e.printStackTrace();
		}	
		
		return i;
	}

測試：

public void test4(){
		Person p = new Person(5,"李蓮英","男",20,"110");
		int i = dao.updatePerson(p);
		if(i>0){
			System.out.println("修改成功！");
		}else{
			System.out.println("修改失敗！");
		}
	}

增刪改：

觀察可以得到，增加刪除和修改操作中大體步驟是相同的，只有sql語句和傳入的引數不同。

考慮把它們合成一條：

public int executeUpdate(String sql, Object...parameters){
		int i = 0;
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		try{
			//關閉事物自動提交
			conn.setAutoCommit(false);
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.為佔位符傳值
			if(parameters!=null && parameters.length>0){
				for(int j=0; j<parameters.length; j++){
					pmst.setObject(j+1, parameters[j]);
				}
			}
			//5.執行sql語句
			i = pmst.executeUpdate();
			//手動提交
			conn.commit();
			//釋放資源
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			//回滾到先前狀態
			System.out.println("出現異常，馬上回滾！");
			try {
				conn.rollback();
			} catch (Exception e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			e.printStackTrace();
		}	
		
		return i;
	}

傳入的引數為sql語句和多個引數Object...parameters。

xxx.setObject(j+1, parameters[j]);中，j+1表示sql語句中的佔位符（從1開始，而j是從0開始），parameters[j]表示傳入的多個引數。

測試：

public void test5(){
		//增加
//		Person p = new Person(6,"魏忠賢","男",35,"1123123");
//		String sql = "insert into users values(?,?,?,?,?)";
//		int i = dao.executeUpdate(sql, p.getId(), p.getName(), p.getSex(), p.getAge(), p.getPhone());
		
		//刪除
//		String sql = "delete from users where id=?";
//		int i = dao.executeUpdate(sql, "1");
		
		//修改
		Person p = new Person(5,"魏忠賢","女",35,"1123123");
		String sql = "update users set name=?, sex=?, age=?, phone=? where id=?";
		int i = dao.executeUpdate(sql, p.getName(), p.getSex(), p.getAge(), p.getPhone(), p.getId());
		
		if(i>0){
			System.out.println("成功！");
		}else{
			System.out.println("失敗！");
		}
	}

測試各項需要分開測試。

查詢所有資訊：

public List<Person> findAllPerson() {
		List<Person> list = new ArrayList<Person>();
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "select * from users order by id ";
		
		try{
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.執行查詢語句
			rs = pmst.executeQuery(sql);
			
			while (rs.next()){
			    int id = rs.getInt(1);
			    String name = rs.getString(2);
				String sex = rs.getString(3);
				int age = rs.getInt(4);
				String phone = rs.getString(5);
				//5.封裝到Person物件中
				Person p = new Person(id, name, sex, age, phone);
				//6.新增到集合中
				list.add(p);
			}
			
			//7.釋放資源
			rs.close();
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			e.printStackTrace();
		}
		
		return list;	
	}

該方法的返回型別為List<Person>，因此首先定義一個該型別的list。

這裡執行查詢語句executeQuery(sql)，與上述的更新語句executeUpdate()不同。

因為list裡面的物件是Person型別的，而getString和getInt方法取出的是String和int型別，因此取出後先封裝到Person中：Person p = new Person(id, name, sex, age, phone);最後再加進list：list.add(p);

測試：

public void test6(){
		List<Person> list = dao.findAllPerson();
		for(Person p:list){
			System.out.println(p);
		}	
	}

按id查詢資訊：

public Person findByIdPerson(int id) {
		Person p = new Person();
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "select * from users where id= "+id;
		
		try{
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.為佔位符傳值(加了這行就報錯)
//			pmst.setInt(1, id);
			//5.執行查詢語句
			rs = pmst.executeQuery(sql);
			rs.next();
			String name = rs.getString(2);
			String sex = rs.getString(3);
			int age = rs.getInt(4);
			String phone = rs.getString(5);
			//6.封裝到Person物件中
			p = new Person(id, name, sex, age, phone);
			
			//釋放資源
                        rs.close();
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			e.printStackTrace();
		}	
		
		return p;
	}

這裡注意返回型別為Person型，跟上個方法不同，它只需要顯示一條資訊，因此僅是少了加入集合的步驟。

測試：

public void test7(){
		Person p = dao.findByIdPerson(10);
		System.out.println(p.toString());
	}

按id刪除多組：

public int deleteManyPerson(int[] id) {
		int i = 0;
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		String sql = "delete from users where id=?";
		
		try{
			//關閉事物自動提交
			conn.setAutoCommit(false);
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			for(int j=0; j<id.length; j++){
				//4.為佔位符傳值
				pmst.setInt(1, id[j]);
				//4.執行sql語句
				i = pmst.executeUpdate();
			}
			//手動提交
			conn.commit();
			//釋放資源
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			//回滾到先前狀態
			System.out.println("出現異常，馬上回滾！");
			try {
				conn.rollback();
			} catch (Exception e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			e.printStackTrace();
		}	
		
		return i;
	}

這裡傳入的是陣列，因此為佔位符傳值時我們使用一個迴圈來多次執行，以達到刪除多項的目的。

測試：

public void test8(){
		int[] id = new int[]{2, 5};
		int i = dao.deleteManyPerson(id);
		if(i>0){
			System.out.println("刪除成功！");
		}else{
			System.out.println("刪除失敗！");
		}
	}

分頁查詢：

在mysql中支援分頁查詢
select * from <表名> limit m,n
m表示從第幾條開始
n表示顯示幾條
分頁時傳遞的是你的當前頁面和每頁顯示的條數
select * from <表名> limit (currentpage-1)*size, size

public List<Person> findByPage(int currentpage, int size) {
		List<Person> list = new ArrayList<Person>();
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.sql語句
		int m = (currentpage-1)*size;
		int n = size;
		String sql = "select * from users limit "+m+","+n;
//		System.out.println(sql);
		
		try{
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql);
			//4.執行查詢語句
			rs = pmst.executeQuery(sql);
			
			while (rs.next()){
				int id = rs.getInt(1);
				String name = rs.getString(2);
				String sex = rs.getString(3);
				int age = rs.getInt(4);
				String phone = rs.getString(5);
				//5.封裝到Person物件中
				Person p = new Person(id, name, sex, age, phone);
				//6.新增到集合中
				list.add(p);
			}
			
			//7.釋放資源
			rs.close();
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			e.printStackTrace();
		}
		
		return list;	
	}

測試：

public void test9(){
		int[] id = new int[]{2, 5};
		int i = dao.deleteManyPerson(id);
		if(i>0){
			System.out.println("刪除成功！");
		}else{
			System.out.println("刪除失敗！");
		}
	}

高階搜尋：

public List<Person> superQuery(Person p){
		List<Person> list = new ArrayList<Person>();
		//1.與資料庫建立連線
		conn = OaUtils.getConnection();
		//2.動態新增sql語句
		StringBuilder sql = new StringBuilder("select * from users where 1=1");//1=1為假條件
		if(p.getName()!=null && p.getName()!=""){
			sql.append(" and name="+"'"+p.getName()+"'");
		}
		if(p.getSex()!=null && p.getSex()!=""){
			sql.append(" and sex="+"'"+p.getSex()+"'");
		}
		if(p.getPhone()!=null && p.getPhone()!=""){
			sql.append(" and phone="+"'"+p.getPhone()+"'");
		}
//		System.out.println(sql.toString());
		try{
			//3.建立PreparedStatement物件
			pmst = conn.prepareStatement(sql.toString());
			//4.執行查詢語句
			rs = pmst.executeQuery();
			
			while (rs.next()){
				int id = rs.getInt(1);
				String name = rs.getString(2);
				String sex = rs.getString(3);
				int age = rs.getInt(4);
				String phone = rs.getString(5);
				//5.封裝到Person物件中
				Person p1 = new Person(id, name, sex, age, phone);
				//6.新增到集合中
				list.add(p1);
			}
			
			//7.釋放資源
			rs.close();
			pmst.close();
			conn.close();
			
		}catch(Exception e){
			e.printStackTrace();
		}
		
		return list;
	}

StringBuilder實現字串的動態拼接，append()；

或者使用String.format(s,....);用佔位符%s和%d也行：

String s = "select * from users where %s %s %s";
String s1="", s2="", s3="";
if(p.getName()!=null && p.getName()!=""){
	s1 = "name='"+p.getName()+"'";
}
if(p.getSex()!=null && p.getSex()!=""){
	s2 = "and sex='"+p.getSex()+"'";
}		
if(p.getPhone()!=null && p.getPhone()!=""){
	s3 = "and phone='"+p.getPhone()+"'";
}
		
String sql = String.format(s, s1, s2, s3);

如要實現模糊查詢，把“=”改成“like”，在欄位前後都加入“%”即可：

s1 = "name like'%"+p.getName()+"%'";

測試：

public void test10(){
		Person p = new Person("name1", "man", null);
		List<Person> list = dao.superQuery(p);
		for(Person p1:list){
			System.out.println(p1);
		}
	}

jsp實現對mysql資料庫的操作

接上，在PersonDao.java中逐項完成方法。 PreparedStatement pmst; Connection conn; ResultSet rs; 增加資料： public int addPerson(Person p) { int i = 0;

Spring+Maven+JdbcTemplate實現對mysql資料庫操作

第一步匯入需要的maven： <dependency> <groupId>org.springframework</groupId> <artifactId>spring-conte

使用Java語言實現對MySQL資料庫的基本操作

在資料庫的使用中最為主要的就是對資料庫的增、刪、查、改操作，MySQL資料庫作為關係型資料庫的一種，其資料庫管理系統是由瑞典MySQL AB 公司開發，目前屬於 Oracle 旗下產品。MySQL 是最流行的關係型資料庫管理系統之一，在 WE

Node.js實現對mysql資料庫的crud時報加密方式錯誤解決方案

本人在學習全棧開發過程中做一個Node的web專案在連線本地MySQL8.0版本的資料庫時，發現Navicat連線不上，它報了一個數據庫的加密方式導致連線不上的錯誤，錯誤如下： MySQL8.0版本的加密方式和MySQL5.0的不一樣，連線會報錯。解決方法如下：開啟mysql的命令列進入

Java實現對mysql資料庫的增刪查改

前面我們已經講過如何實現對mysql資料庫的連線。最簡單的資料庫操作就是增刪查改。其實對懂得實現對資料庫的連線，其餘的，對於一些簡單的操作都是很簡單的。檢視資料 public static void show_info() throws ClassNotFoundExcept

java實現對mysql資料庫連線

我們需要一個JDBC的庫檔案. 所謂JDBC是用於執行Sql語句的JAVA API，有了這個包就可簡單對mysql進行連線等操作。首先，實現對資料庫的連線。 public class mysql_connect { static String sql; public st

用java實現對MySql資料庫中資料的讀取、插入、修改和刪除

目標： 1、實現eclipse同資料庫的連線 2、在eclipse中用java實現對資料庫的控制初學java和資料庫，本文是參考這篇文章的思路的學習筆記，程式碼實現了將4個控制函式（讀取、插入、修改和刪除）分別寫成4個靜態方法呼叫。 1. 關於java和MySQL的連

(二)mybatis學習之實現對mySQL資料庫的增刪查改

package com.loren.entity; import org.apache.ibatis.type.Alias; //@Alias()為實體類指定新的別名 @Alias("emp"

Java如何實現對Mysql資料庫的行鎖

@Transactional @Override public boolean increaseBalanceByLock(Long userId, BigDecimal amount) throws ValidateException { long tim

thinkphp實現對MySQL資料庫實現備份功能

public function exportDatabase(){ header("Content-type:text/html;charset=utf-8"); $path = C('ROOT_MYSQL_PATH'); $model = M(); //查詢所有表 $sq

Java 下實現對mysql資料庫的備份和恢復

在java裡面使用 Java.lang.Runtime 執行系統系統執行環境裡面的命令，從而使用mysql自帶的備份及恢復工具達到對資料庫的備份和恢復package org.hinsteny.util; import java.io.File; import java.i

JSP實現HTML網頁對Mysql資料庫的資料修改

<% request.setCharacterEncoding("utf-8"); String msg=""; String msg1=""; boolean error=false; 獲取網址中傳遞的Id String origId = request.getParameter("pid"); S

shell實現對mysql數據庫的增、刪、改、查操作

shell實現對mysql的增、刪、改、shell實現對mysql數據庫的增、刪、改、查操作 #!/bin/bash　 #數據庫信息 HOSTNAME="192.168.111.84" PORT="3306" USERNAM

DJANGO專案用WEB的方式對MYSQL資料庫進行備份匯出等管理任務的實現

環境：PYTHON2.7，DJANGO1.9.9 urls.py 加一行： url(r'^mysqldatamanage/', views.mysqldatamanage,name='mysqldatamanage'), views.py新增對應的方mysqldatam

Spring Boot 2.x使用Spring Data Jpa對MySQL資料庫進行CRUD操作

只需兩步！Eclipse+Maven快速構建第一個Spring Boot專案構建了第一個Spring Boot專案。 Spring Boot連線MySQL資料庫連線了MySQL資料庫。本文在之前的基礎上，使用Spring Data Jpa對MySQL

Hibernate對mysql資料庫的操作

hibernate相對於mybatis來說，他是一個重量級的框架，可能比mybatis更加讓人不能夠理解一點，但是如果你從開始首先接觸hibernate，那麼由深到淺就容易得多了。用到hibernate，首先我們需要匯入hibernate所需要的jar包，或者用myecl

對Mysql資料庫的基本操作的一些總結

Mysql資料庫的基本操作總注：所有sql語句結尾處最好加上分號符; MySQL中的一些語句使用方法： #檢視所有的資料庫 show databases; #檢視資料庫下所有的表 show tables; 注：sql語句不區分大小寫，但是嚴重區分中英文

C++對MySQL資料庫進行匯出和匯入操作

相信大家應該在網上看到很多利用SQL語句對MySQL資料庫的表或者資料庫本身進行匯出和匯入操作。在window環境下利用dos命令列匯出資料庫（我的mysq直接裝在c盤根目錄下下，其bin目錄為：c:/mysql/bin）： 1、執行MySQL資料庫匯出操作： c:\my

MySQL資料庫操作類(PHP實現，支援連貫操作)

<?php /** * Author: helen * CreateTime: 2016/4/12 20:14 * description: 資料庫操作類(僅對接MySQL資料庫,主要利用MySQLi函式) */ class Database{ //MySQL主機地址 priv

初識和利用Servlet，獲取和顯示頁面提交的資料以及對MySQL資料庫的簡單操作 7.04

Servlet：web伺服器端的程式設計技術。是繼承了javax.servlet.http.HttpServlet類的Java類。由支援servlet的web伺服器（tomcat）呼叫和啟動執行。一個

jsp實現對mysql資料庫的操作

增加資料：

事物：

刪除單條資料：

修改資料：

增刪改：

查詢所有資訊：

按id查詢資訊：

按id刪除多組：

分頁查詢：

高階搜尋：

相關推薦