java學(xué)生信息管理系統(tǒng)設(shè)計（2）
更新時間：2016年11月15日 16:49:39 作者：xanlv
這篇文章主要為大家詳細(xì)介紹了java學(xué)生信息管理系統(tǒng)設(shè)計，學(xué)生信息添加進入數(shù)據(jù)庫的事務(wù),具有一定的參考價值，感興趣的小伙伴們可以參考一下
本例的學(xué)生信息添加進入數(shù)據(jù)庫的事務(wù)(可以提交事務(wù),事務(wù)回滾,用本地線程完善)
主頁面index.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %> <html> <head> <title>學(xué)生信息管理</title> </head> <body> <a href='<c:url value="/query"/>?cmd=query'>查看學(xué)生信息</a> <br><br> <!-- <a href="<c:url value='/StudServlet?cmd=save' />">學(xué)生信息添加</a> --> <h2>學(xué)生信息添加</h2> <form action='<c:url value="/query"/>?cmd=add' method="post"> 姓名:<input type="text" name="name"/><br><br> <fieldset style="border: solid;border-color: red;width: 250px;"> <legend>圖書1</legend> 書名:<input type="text" name="book"/><br><br> 價格:<input type="text" name="price"/> </fieldset> <br> <fieldset style="border: solid;border-color:green;width: 250px;"> <legend>圖書2</legend> 書名:<input type="text" name="book"/><br><br> 價格:<input type="text" name="price"/> </fieldset> <br><br> <input type="submit" value="提交"/><br><br> </form> </body> </html>
工具包
獲取數(shù)據(jù)庫連接的工具ConnUtils5.java
package cn.hncu.utils;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
public class ConnUtils5 {
//本地線程管理對象，用于實現(xiàn): 同一個線程獲取的連接是同一個
private static ThreadLocal< Connection> t=new ThreadLocal<Connection>();
private final static List<Connection> pool=new ArrayList<Connection>();
private static int SIZE;//由資源文件讀取
private ConnUtils5(){
}
static{
Properties p=new Properties();
try {
//下面這種方式在純Java項目中可以讀取到classpath下的資源文件，但無法讀取JavaEE項目的。因為Tomcat把系統(tǒng)的默認(rèn)類加載器改了
//p.load( ClassLoader.getSystemClassLoader().getSystemResourceAsStream("jdbc.properties"));
// p.load(ClassLoader.getSystemResourceAsStream("jdbc.properties"));
//讀取Web項目的classpath下的資源文件,用這個可以
p.load(ConnUtils3.class.getClassLoader().getResourceAsStream("jdbc.properties"));
String driver=p.getProperty("driver");
String url=p.getProperty("url");
String name=p.getProperty("username");
String pwd=p.getProperty("password");
String ssize=p.getProperty("size");
SIZE=Integer.parseInt(ssize);
Class.forName(driver);
for(int i=0;i<SIZE;i++){
final Connection con=DriverManager.getConnection(url,name,pwd);
System.out.println("con=="+con);
//更改conn.close()方法
//用代理模式生成一個增強版的conn對象，把它的close()方法攔截更改掉
Object nCon=Proxy.newProxyInstance(
ConnUtils3.class.getClassLoader(),
// conn.getClass().getInterfaces(),
//后面這種方式不行,應(yīng)該是驅(qū)動中的實現(xiàn)類和我們當(dāng)前程序不在同一空間(類加載器不同)
new Class[]{Connection.class},
new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
if(method.getName().equals("close")){
System.out.println("還回一個鏈接："+(Connection)proxy);
pool.add((Connection)proxy);
return null;
}
return method.invoke(con, args);
}
});
pool.add((Connection)nCon);
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static synchronized Connection getConnection(){
//先從t中拿，如果有就拿出去，如果沒有再到池中拿且把該對象放到t中
Connection con=t.get();
if(con==null){
if(pool.size()<=0){
System.out.println("池中連接沒有了...");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return getConnection();
}
con=pool.remove(0);
t.set(con);//放到t中
}
return con;//拿一個移一個
}
}
代理
package cn.hncu.utils;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
public class TxProxy implements InvocationHandler {
private Object srcObj=null;
private TxProxy(Object srcObj) {
this.srcObj = srcObj;
}
public static Object getProxy(Object srcObj){
System.out.println("srcObj:"+srcObj);
Object newObj=Proxy.newProxyInstance(
TxProxy.class.getClassLoader(),
srcObj.getClass().getInterfaces(),
new TxProxy(srcObj));
System.out.println("newObj:"+newObj);
return newObj;
}
@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
Connection con=null;
Object returnObj=null;
try {
con=ConnUtils5.getConnection();
System.out.println("invoke拿到一個鏈接："+con);
con.setAutoCommit(false);
returnObj=method.invoke(srcObj, args);
System.out.println("提交一個事務(wù)...");
con.commit();
} catch (Exception e) {
try {
System.out.println("回滾一個事務(wù)...");
con.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}finally{
try {
con.setAutoCommit(true);
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return returnObj;
}
}
代理2:不需要強轉(zhuǎn),但是代理了所有
package cn.hncu.utils;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
public class TxProxy2 implements InvocationHandler {
private Object srcObj=null;
private TxProxy2(Object srcObj) {
this.srcObj = srcObj;
}
public static<T> T getProxy(Class<T> c){
Object obj=null;
try {
obj = c.newInstance();
} catch (Exception e) {
e.printStackTrace();
}
Object newObj=Proxy.newProxyInstance(
TxProxy2.class.getClassLoader(),
c.getInterfaces(),
new TxProxy2(obj));
return (T) newObj;
}
@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
Connection con=null;
Object returnObj=null;
try {
con=ConnUtils5.getConnection();
System.out.println("invoke拿到一個鏈接："+con);
con.setAutoCommit(false);
returnObj=method.invoke(srcObj, args);
System.out.println("提交一個事務(wù)...");
con.commit();
} catch (Exception e) {
try {
System.out.println("回滾一個事務(wù)...");
con.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}finally{
try {
con.setAutoCommit(true);
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return returnObj;
}
}
注解
package cn.hncu.utils;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(value=ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Transaction {
}
代理3:用注解實現(xiàn)需要事務(wù)則用事務(wù)
package cn.hncu.utils;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
public class TxProxy3 implements InvocationHandler {
private Object srcObj=null;
private TxProxy3(Object srcObj) {
this.srcObj = srcObj;
}
public static<T> T getProxy(T srcObj){
Object newObj=Proxy.newProxyInstance(
TxProxy3.class.getClassLoader(),
srcObj.getClass().getInterfaces(),
new TxProxy3(srcObj));
return (T) newObj;
}
@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
/* 這種方式來實現(xiàn)只攔截指定的方法
if(method.getName().equals("close")){
...攔截
}else{
return method.invoke(srcObj, args);
}
*/
if(method.isAnnotationPresent(Transaction.class)){
Connection con=null;
Object returnObj=null;
try {
con=ConnUtils5.getConnection();
System.out.println("invoke拿到一個鏈接："+con);
con.setAutoCommit(false);
//真正的業(yè)務(wù)代碼，放行
returnObj=method.invoke(srcObj, args);
System.out.println("提交一個事務(wù)...");
con.commit();
} catch (Exception e) {
try {
System.out.println("回滾一個事務(wù)...");
con.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
}finally{
try {
con.setAutoCommit(true);
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return returnObj;
}else{
System.out.println("不存在事務(wù)注解，直接放行!");
return method.invoke(srcObj, args);
}
}
}
資源文件jdbc.properties
##MySQL driver=com.mysql.jdbc.Driver url=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8 username=root password=1234 size=3 ##Oracle #driver=oracle.jdbc.driver.OracleDriver #url=jdbc:oracle:thin:@127.0.0.1:1521:orcl #username=scott #password=tiger
stud層的servlet層–QueryServlet.java
package cn.hncu.stud.servlet;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import cn.hncu.domain.Book;
import cn.hncu.domain.Stud;
import cn.hncu.stud.service.IStudService;
import cn.hncu.stud.service.StudServiceImpl;
import cn.hncu.utils.TxProxy3;
public class QueryServlet extends HttpServlet {
//注入
//1.
// IStudService service=(IStudService) TxProxy.getProxy(new StudServiceImpl());
//2.
// IStudService service=TxProxy2.getProxy(StudServiceImpl.class);
//3.
IStudService service=TxProxy3.getProxy(new StudServiceImpl());
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String cmd=request.getParameter("cmd");
System.out.println("cmd:"+cmd);
if("query".equals(cmd)){
query(request, response);
}else if("add".equals(cmd)){
add(request, response);
}
}
public void query(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
System.out.println("service:"+service);
List<Map<String, String>> studs=service.query();
request.setAttribute("studs", studs);
request.getRequestDispatcher("/jsps/show.jsp").forward(request, response);
}
public void add(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//1收集參數(shù) 2組織參數(shù)(id字段留到dao中去補)
String name[]=request.getParameterValues("name");
Stud s=new Stud();
s.setName(name[0]);
//圖書信息
String books[]=request.getParameterValues("book");
//防護一下 ---價格的防護應(yīng)該也要寫，這里我們偷懶了
if(books==null||books.length<=0){
return;
}
String prices[]=request.getParameterValues("price");
for(int i=0;i<books.length;i++){
Book b=new Book();
b.setName(books[i]);
b.setPrice(Double.parseDouble(prices[i]));
//※完成兩個值對象的“一對多”關(guān)系的數(shù)據(jù)封裝
s.getBooks().add(b);//一方
b.setS(s);//多方
}
//3調(diào)用service層
try {
service.save(s);
} catch (Exception e) {
//導(dǎo)向失敗頁面
}
}
}
stud層的service層–
接口：
package cn.hncu.stud.service;
import java.util.List;
import java.util.Map;
import cn.hncu.domain.Stud;
import cn.hncu.utils.Transaction;
public interface IStudService {
public List<Map<String, String>> query();
//注意，注解只有放在接口才有用,,,,寫在實現(xiàn)類中的方法無效(不會決定開啟事務(wù))
@Transaction
public void save(Stud stud) throws Exception ;
}
實現(xiàn)類
package cn.hncu.stud.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import cn.hncu.domain.Stud;
import cn.hncu.stud.dao.BookDAO;
import cn.hncu.stud.dao.BookJdbcDao;
import cn.hncu.stud.dao.StudDAO;
import cn.hncu.stud.dao.StudJdbcDAO;
import cn.hncu.utils.ConnUtils5;
/*我們以后開發(fā)時通常都要采用一個dao獨立操作一個表,系統(tǒng)中有幾個實體表就寫幾個dao，
* 以后框架都是這么干的，我們也要這樣做，因為架構(gòu)好！
*
* 采用事務(wù)的場合:
* 1、如果只有一個dao，但要執(zhí)行多條sql語句且涉及增刪改，則要開啟事務(wù)
* 2、如果一個service調(diào)用多個dao，通常也要開啟事務(wù)。
*/
public class StudServiceImpl implements IStudService {
//注入
StudDAO dao_stud=new StudJdbcDAO();
BookDAO dao_book=new BookJdbcDao();
@Override
public List<Map<String, String>> query() {
return dao_stud.query();
}
@Override
public void save(Stud stud) throws Exception {
dao_stud.save(stud);
dao_book.save(stud.getBooks());
}
}
stud層的dao層–
Stud接口–分離式做法,一個表對應(yīng)一個dao,為框架做準(zhǔn)備
package cn.hncu.stud.dao;
import java.util.List;
import java.util.Map;
import cn.hncu.domain.Stud;
public interface StudDAO {
public List<Map<String, String>> query();
public void save(Stud stud) throws Exception;
}
Stud實現(xiàn)類
package cn.hncu.stud.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import cn.hncu.domain.Book;
import cn.hncu.domain.Stud;
import cn.hncu.utils.ConnUtils3;
public class StudJdbcDAO implements StudDAO {
@Override
public List<Map<String, String>> query() {
List<Map<String, String>> list=new ArrayList<Map<String,String>>();
//一個map就是一行數(shù)據(jù)， List<Map>就是整個數(shù)據(jù)表
Connection con=null;
try {
con=ConnUtils3.getConnection();
Statement st=con.createStatement();
String sql="select * from stud";
ResultSet rs=st.executeQuery(sql);
while(rs.next()){
Map<String,String> m=new HashMap<String, String>();
m.put("id", (String) rs.getObject(1));
m.put("name", (String) rs.getObject(2));
list.add(m);
}
rs.close();
st.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return list;
}
@Override
public void save(Stud stud) throws Exception {
Connection con=ConnUtils3.getConnection();
System.out.println("拿到一個鏈接："+con);
String sql="insert into stud values(?,?)";
String uuid=UUID.randomUUID().toString().replace("-", "");
PreparedStatement pst=con.prepareStatement(sql);
stud.setId(uuid);//為了"多方"即book能夠拿到"一方"的id，專門補的
pst.setString(1, uuid);
pst.setString(2, stud.getName());
System.out.println("1:"+uuid+",2:"+stud.getName());
pst.executeUpdate();
// con.close();//拿到同一個con,這里就不需要關(guān)了
}
}
Book接口
package cn.hncu.stud.dao;
import java.util.List;
import cn.hncu.domain.Book;
public interface BookDAO {
public void save(List<Book> books) throws Exception;
}
Book實現(xiàn)類
package cn.hncu.stud.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.util.List;
import cn.hncu.domain.Book;
import cn.hncu.utils.ConnUtils3;
public class BookJdbcDao implements BookDAO {
@Override
public void save(List<Book> books) throws Exception {
Connection con=ConnUtils3.getConnection();
System.out.println("拿到一個鏈接："+con);
String sql="insert into book(name,price,studid) values(?,?,?)";
PreparedStatement pst=con.prepareStatement(sql);
for(Book b:books){
pst.setString(1, b.getName());
pst.setDouble(2, b.getPrice());
pst.setObject(3, "12132312");//異常(故意給一個不存在的外鍵字段，以測試事務(wù)回滾)--測事務(wù)回滾
// pst.setObject(3, b.getS().getId());
System.out.println("1:"+b.getName()+",2:"+b.getPrice()+",3:"+b.getS().getId());
pst.addBatch();//添加到批處理
}
pst.executeBatch();//執(zhí)行批處理
// con.close();//這里拿到同一個con，這里不需要關(guān)
}
}
值對象
Stud對象
package cn.hncu.domain;
import java.util.ArrayList;
import java.util.List;
/*
* 一對多中的 “一”方 值對象的建法
*/
public class Stud {
private String id;
private String name;
//※專為“多”方添加一個集合---體現(xiàn)多表中的“一對多關(guān)系”
private List<Book> books=new ArrayList<Book>();//注意，該集合要在構(gòu)造時或之前就new出來。
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public List<Book> getBooks() {
return books;
}
public void setBooks(List<Book> books) {
this.books = books;
}
@Override
public String toString() {
return "id=" + id + "," + name + "," + books;
}
}
Book對象
package cn.hncu.domain;
/*
* 一對多中的 “多”方 值對象的建法
*/
public class Book {
private Integer id;
//基本數(shù)據(jù)類型全部用包裝類的聲明，為以后使用框架做技術(shù)準(zhǔn)備---包裝類能夠兼容框架(因為一般框架都會使用類反射)
private String name;
private Double price;
//※專為“一”方添加一個對象類型的變量(注意，不用studid)---體現(xiàn)多表中的“一對多關(guān)系”
private Stud s;//設(shè)置主人
//private String studid;//★★不要這樣設(shè)
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Double getPrice() {
return price;
}
public void setPrice(Double price) {
this.price = price;
}
public Stud getS() {
return s;
}
public void setS(Stud s) {
this.s = s;
}
/*
* 多表關(guān)聯(lián)時的toString()方法要注意一個陷阱，就是一方輸出另一方，同時另一方又反過來輸出前一方，形成無窮遞歸！
*/
@Override
public String toString() {
return "id=" + id + "," + name + "," + price;//這里不能輸出Stud對象，否則無窮遞歸
}
}
顯示學(xué)生信息頁面jsps/show.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
<html>
<head>
<title>學(xué)生信息管理</title>
</head>
<body>
<h2>學(xué)生信息</h2>
<c:forEach items="${studs}" var="x">
${x.id},${x.name}<br/>
</c:forEach>
</body>
</html>
效果圖：
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
相關(guān)文章
這篇文章主要介紹了Java8中的Stream?流實踐操作，Stream?是?java8?中處理集合的抽象概念，可以執(zhí)行非常復(fù)雜的查詢、過濾和映射數(shù)據(jù)等操作，下文更多相關(guān)資料介紹,需要的朋友可以參考一下2022-05-05
這篇文章主要介紹Java多線程之同步工具類CyclicBarrier,它是一個同步工具類，它允許一組線程互相等待，直到達到某個公共屏障點，支持一個可選的Runnable命令，在一組線程中的最后一個線程到達之后,該命令只在每個屏障點運行一次。下面來看文章具體內(nèi)容2021-10-10
在我們使用手機通訊錄或各種APP的搜索功能時,既可以根據(jù)中文搜索,也可以根據(jù)拼音搜索,這種時候就使用到了中文轉(zhuǎn)拼音的功能了,下面這篇文章主要給大家介紹了關(guān)于Java將中文轉(zhuǎn)化為拼音的簡單代碼示例,需要的朋友可以參考下2024-03-03
本文以最簡明扼要的例子將Java的回調(diào)機制介紹給大家，感興趣的朋友可以參考一下。2016-07-07
基于Java SWFTools實現(xiàn)把pdf轉(zhuǎn)成swf
這篇文章主要介紹了基于Java SWFTools實現(xiàn)把pdf轉(zhuǎn)成swf,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-11-11
隊列作為基礎(chǔ)的數(shù)據(jù)結(jié)構(gòu)，是程序員的入門課。也是所有程序員必須掌握的一種數(shù)據(jù)結(jié)構(gòu)，隊列在程序中廣泛應(yīng)用，因此我們應(yīng)該對隊列有深入的了解，接下來我們通過代碼來對隊列這種數(shù)據(jù)結(jié)構(gòu)進行深度解析，感興趣的朋友一起看看吧2021-09-09
SpringMVC使用@Valid注解進行數(shù)據(jù)驗證的方法
本篇文章主要介紹了SpringMVC使用@Valid注解進行數(shù)據(jù)驗證的方法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-02-02
這篇文章主要給大家介紹了關(guān)于SpringBoot中使用Redis的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
這篇文章主要介紹了spring整合redisson開啟緩存方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
在實際工作中，當(dāng)使用JMeter做性能腳本或者接口腳本時，當(dāng)遇到需要對不同的條件做不同的操作時，我們可以使用JMeter中if控制器來實現(xiàn)，本文就詳細(xì)的介紹一下如何使用2021-11-11