多平台统一管理软件接口,如何实现多平台统一管理软件接口
234
2023-06-29
java学生信息管理系统设计
本例的学生信息添加进入数据库的事务(可以提交事务,事务回滚,用本地线程完善)
主页面index.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
nJNtinZb
姓名:
书名:
价格:
书名:
价格:
获取数据库连接的工具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 {
//本地线程管理对象,用于实现: 同一个线程获取的连接是同一个
private static ThreadLocal< Connection> t=new ThreadLocal
private final static List
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 final Connection con=DriverManager.getConnection(url,name,pwhttp://d); 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;//拿一个移一个 } } 资源文件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.java package cn.hncu.domain; import java.util.ArrayList; import java.util.List; /* * 一对多中的 “一”方 值对象的建法 */ public class Stud { private String id; private String name; //※专为“多”方添加一个集合---体现多表中的“一对多关系” private List 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 return books; } public void setBooks(List this.books = books; } @Override public String toString() { return "id=" + id + "," + name + "," + books; } } Book.java package cn.hncu.domain; /* * 一对多中的 “多”方 值对象的建法 */ public class Book { private Integer id; //基本数据类型全部用包装类的声明,为以后使用框架做技术准备---包装类能够兼容框架(因为一般框架都会使用类反射) private String name; private Double price; //※专为“一”方添加一个对象类型的变量(注意,不用studid)---体现多表中的“一对多关系” private Stud s;//设置主人 http:////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对象,否则无穷递归 } } 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; public class QueryServlet extends HttpServlet { //注入 IStudService service=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 { List 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"); System.out.println(name[0]); 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 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层– 接口: package cn.hncu.stud.service; import java.util.List; import java.util.Map; import cn.hncu.domain.Stud; public interface IStudService { public List public void save(Stud stud); } 实现类 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.ConnUtils3; /*我们以后开发时通常都要采用一个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 return dao_stud.query(); } @Override public void save(Stud stud) { Connection con=null; try { con=ConnUtils3.getConnection(); System.out.println("拿到一个链接:"+con); con.setAutoCommit(false); dao_stud.save(stud); dao_book.save(stud.getBooks()); 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(); } } } } stud层的dao层– Stud接口 package cn.hncu.stud.dao; import java.util.List; import java.util.Map; import cn.hncu.domain.Stud; public interface StudDAO { public List public void save(Stud stud) throws Exception; } Stud实现类 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 List //一个map就是一行数据, List 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 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(); Shttp://ystem.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接口 package cn.hncu.stud.dao; import java.util.List; import cn.hncu.domain.Book; public interface BookDAO { public void save(List } Book实现类 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 Connection con=ConnUtils3.getConnection(); System.out.println("拿到一个链接:"+con); String sqnJNtinZbl="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,这里不需要关 } } 显示学生信息页面jsps/show.jsp <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
final Connection con=DriverManager.getConnection(url,name,pwhttp://d);
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;//拿一个移一个
}
}
资源文件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.java
package cn.hncu.domain;
import java.util.ArrayList;
import java.util.List;
/*
* 一对多中的 “一”方 值对象的建法
*/
public class Stud {
private String id;
private String name;
//※专为“多”方添加一个集合---体现多表中的“一对多关系”
private List
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
return books;
}
public void setBooks(List
this.books = books;
}
@Override
public String toString() {
return "id=" + id + "," + name + "," + books;
}
}
Book.java
package cn.hncu.domain;
/*
* 一对多中的 “多”方 值对象的建法
*/
public class Book {
private Integer id;
//基本数据类型全部用包装类的声明,为以后使用框架做技术准备---包装类能够兼容框架(因为一般框架都会使用类反射)
private String name;
private Double price;
//※专为“一”方添加一个对象类型的变量(注意,不用studid)---体现多表中的“一对多关系”
private Stud s;//设置主人
http:////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对象,否则无穷递归
}
}
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;
public class QueryServlet extends HttpServlet {
//注入
IStudService service=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 {
List
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");
System.out.println(name[0]);
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 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层– 接口: package cn.hncu.stud.service; import java.util.List; import java.util.Map; import cn.hncu.domain.Stud; public interface IStudService { public List public void save(Stud stud); } 实现类 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.ConnUtils3; /*我们以后开发时通常都要采用一个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 return dao_stud.query(); } @Override public void save(Stud stud) { Connection con=null; try { con=ConnUtils3.getConnection(); System.out.println("拿到一个链接:"+con); con.setAutoCommit(false); dao_stud.save(stud); dao_book.save(stud.getBooks()); 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(); } } } } stud层的dao层– Stud接口 package cn.hncu.stud.dao; import java.util.List; import java.util.Map; import cn.hncu.domain.Stud; public interface StudDAO { public List public void save(Stud stud) throws Exception; } Stud实现类 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 List //一个map就是一行数据, List 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 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(); Shttp://ystem.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接口 package cn.hncu.stud.dao; import java.util.List; import cn.hncu.domain.Book; public interface BookDAO { public void save(List } Book实现类 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 Connection con=ConnUtils3.getConnection(); System.out.println("拿到一个链接:"+con); String sqnJNtinZbl="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,这里不需要关 } } 显示学生信息页面jsps/show.jsp <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
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层–
接口:
package cn.hncu.stud.service;
import java.util.List;
import java.util.Map;
import cn.hncu.domain.Stud;
public interface IStudService {
public List
public void save(Stud stud);
}
实现类
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.ConnUtils3;
/*我们以后开发时通常都要采用一个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
return dao_stud.query();
}
@Override
public void save(Stud stud) {
Connection con=null;
try {
con=ConnUtils3.getConnection();
System.out.println("拿到一个链接:"+con);
con.setAutoCommit(false);
dao_stud.save(stud);
dao_book.save(stud.getBooks());
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();
}
}
}
}
stud层的dao层–
Stud接口
package cn.hncu.stud.dao;
import java.util.List;
import java.util.Map;
import cn.hncu.domain.Stud;
public interface StudDAO {
public List
public void save(Stud stud) throws Exception;
}
Stud实现类
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
List
//一个map就是一行数据, List
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
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();
Shttp://ystem.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接口
package cn.hncu.stud.dao;
import java.util.List;
import cn.hncu.domain.Book;
public interface BookDAO {
public void save(List
}
Book实现类
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
Connection con=ConnUtils3.getConnection();
System.out.println("拿到一个链接:"+con);
String sqnJNtinZbl="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,这里不需要关
}
}
显示学生信息页面jsps/show.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
${x.id},${x.name}
效果图:
关于管理系统的更多内容请点击《管理系统专题》进行学习
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
发表评论
暂时没有评论,来抢沙发吧~