本例的學生信息添加進入數據庫的事務(可以提交事務,事務回滾,用本地線程完善)
主頁面index.jsp
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%><%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %><html> <head> <title>學生信息管理</title> </head> <body> <a href='<c:url value="/query"/>?cmd=query'>查看學生信息</a> <br><br> <!-- <a href="<c:url value='/StudServlet?cmd=save' />">學生信息添加</a> --> <h2>學生信息添加</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> |
工具包
獲取數據庫連接的工具ConnUtils5.java
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
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 { //本地線程管理對象，用于實現: 同一個線程獲取的連接是同一個 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把系統的默認類加載器改了 //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(), //后面這種方式不行,應該是驅動中的實現類和我們當前程序不在同一空間(類加載器不同) 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;//拿一個移一個 }} |
代理
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
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("提交一個事務..."); con.commit(); } catch (Exception e) { try { System.out.println("回滾一個事務..."); con.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } }finally{ try { con.setAutoCommit(true); con.close(); } catch (SQLException e) { e.printStackTrace(); } } return returnObj; }} |
代理2:不需要強轉,但是代理了所有
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
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("提交一個事務..."); con.commit(); } catch (Exception e) { try { System.out.println("回滾一個事務..."); con.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } }finally{ try { con.setAutoCommit(true); con.close(); } catch (SQLException e) { e.printStackTrace(); } } return returnObj; }} |
注解
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
|
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:用注解實現需要事務則用事務
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
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 { /* 這種方式來實現只攔截指定的方法 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); //真正的業務代碼，放行 returnObj=method.invoke(srcObj, args); System.out.println("提交一個事務..."); con.commit(); } catch (Exception e) { try { System.out.println("回滾一個事務..."); 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("不存在事務注解，直接放行!"); return method.invoke(srcObj, args); } }} |
資源文件jdbc.properties
|
1
|
|
2
3
4
5
6
7
8
9
10
11
|
##MySQLdriver=com.mysql.jdbc.Driverurl=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8username=rootpassword=1234size=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
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
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收集參數 2組織參數(id字段留到dao中去補) String name[]=request.getParameterValues("name"); Stud s=new Stud(); s.setName(name[0]); //圖書信息 String books[]=request.getParameterValues("book"); //防護一下 ---價格的防護應該也要寫，這里我們偷懶了 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])); //※完成兩個值對象的“一對多”關系的數據封裝 s.getBooks().add(b);//一方 b.setS(s);//多方 } //3調用service層 try { service.save(s); } catch (Exception e) { //導向失敗頁面 } }} |
stud層的service層–
接口：
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
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(); //注意，注解只有放在接口才有用,,,,寫在實現類中的方法無效(不會決定開啟事務) @Transaction public void save(Stud stud) throws Exception ;} |
實現類
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
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;/*我們以后開發時通常都要采用一個dao獨立操作一個表,系統中有幾個實體表就寫幾個dao， * 以后框架都是這么干的，我們也要這樣做，因為架構好！ * * 采用事務的場合: * 1、如果只有一個dao，但要執行多條sql語句且涉及增刪改，則要開啟事務 * 2、如果一個service調用多個dao，通常也要開啟事務。 */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接口–分離式做法,一個表對應一個dao,為框架做準備
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
|
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實現類
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
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就是一行數據， List<Map>就是整個數據表 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,這里就不需要關了 }} |
Book接口
|
1
|
|
2
3
4
5
6
7
8
9
10
|
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實現類
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
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");//異常(故意給一個不存在的外鍵字段，以測試事務回滾)--測事務回滾// pst.setObject(3, b.getS().getId()); System.out.println("1:"+b.getName()+",2:"+b.getPrice()+",3:"+b.getS().getId()); pst.addBatch();//添加到批處理 } pst.executeBatch();//執行批處理// con.close();//這里拿到同一個con，這里不需要關 }} |
值對象
Stud對象
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
package cn.hncu.domain;import java.util.ArrayList;import java.util.List;/* * 一對多中的 “一”方 值對象的建法 */public class Stud { private String id; private String name; //※專為“多”方添加一個集合---體現多表中的“一對多關系” private List<Book> books=new ArrayList<Book>();//注意，該集合要在構造時或之前就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對象
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
package cn.hncu.domain;/* * 一對多中的 “多”方 值對象的建法 */public class Book { private Integer id; //基本數據類型全部用包裝類的聲明，為以后使用框架做技術準備---包裝類能夠兼容框架(因為一般框架都會使用類反射) private String name; private Double price; //※專為“一”方添加一個對象類型的變量(注意，不用studid)---體現多表中的“一對多關系” private Stud s;//設置主人 //private String studid;//★★不要這樣設 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; } /* * 多表關聯時的toString()方法要注意一個陷阱，就是一方輸出另一方，同時另一方又反過來輸出前一方，形成無窮遞歸！ */ @Override public String toString() { return "id=" + id + "," + name + "," + price;//這里不能輸出Stud對象，否則無窮遞歸 }} |
顯示學生信息頁面jsps/show.jsp
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%><%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %><html> <head> <title>學生信息管理</title> </head> <body> <h2>學生信息</h2> <c:forEach items="${studs}" var="x"> ${x.id},${x.name}<br/> </c:forEach> </body></html> |
效果圖：
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
