微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

java学生信息管理系统设计2

分类：Java作者：编程之家AI导航网

本例的学生信息添加进入数据库的事务(可以提交事务,事务回滚,用本地线程完善)

主页面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>学生信息管理</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

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;//拿一个移一个
 }


}

代理

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,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:不需要强转,但是代理了所有

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,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;
 }

}

注解

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:用注解实现需要事务则用事务

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(),new TxProxy3(srcObj));
 return (T) newObj;
 }

 @Override
 public Object invoke(Object proxy,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

##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层CQueryServlet.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,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,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,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层C
接口：

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 ;
}

实现类

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层C
Stud接口C分离式做法,一个表对应一个dao,为框架做准备

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实现类

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接口

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实现类

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对象

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对象

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 + "," + price;//这里不能输出Stud对象，否则无穷递归
 }

}

显示学生信息页面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>学生信息管理</title>
 </head>

 <body>
 <h2>学生信息</h2>
 <c:forEach items="${studs}" var="x">
 ${x.id},${x.name}<br/>
 </c:forEach>
 </body>
</html>

效果图：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程小技巧。

您可能感兴趣的文章:

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

String真的不可变吗？
Java中的String是不可变对象 在面向对象及函数编程语言中，不可变对象（英语：Immutable object）是一种对象，在被创造之后，它的状态就不可以被改变。至于状态可以被改变的对象，则被称为可变对象（英语：mutable object）。-- 来自百度百科 Java8 String源码
String, StringBuffer 和 StringBuilder之间的区别
String, StringBuffer 和 StringBuilder 可变性 String不可变 StringBuffer 和 StringBuilder 可变 线程安全 String 不可变，因此是线程安全的 StringBuilder不是线程安全的 StringBuffer 是线程安全的，内
讲讲Java的序列化反序列化？
序列化：把对象转换为字节序列的过程称为对象的序列化. 反序列化：把字节序列恢复为对象的过程称为对象的反序列化. 什么时候会用到 当只在本地 JVM 里运行下 Java 实例，这个时候是不需要什么序列化和反序列化的，但当出现以下场景时，就需要序列化和反序列化了： 当需要将内存中的对象持久化到磁盘，数据
数组到底是不是对象
先说结论，是对象！可以继续往下看 数组是不是对象 什么是对象？对象是类的一个实例，有状态和行为 Java对象： 软件的对象也有行为和状态 软件对象的状态称之为属性 方法操作对象内部状态的改变，对象的相互调用也是通过方法来完成 而java中的数组具有java中其他对象的一些基本特点。比如封装了一些数据
金融、支付行业的开发者不得不知道的float、double计算误差问题
为什么浮点数 float 或 double 运算的时候会有精度丢失的风险呢？ 《阿里巴巴 Java 开发手册》中提到：“浮点数之间的等值判断，基本数据类型不能用 == 来比较，包装数据类型不能用 equals 来判断”。“为了避免精度丢失，可以使用 BigDecimal 来进行浮点数的运算”。 浮点
浅谈Integer缓存机制原理
面试题引入 这里引申出一个经典问题，看下面代码 Integer a = 100; Integer b = 100; System.out.println(a == b);//true Integer c = 200; Integer d = 200; System.out.println(c ==
能否自定义一个String类使用
先说下结论，可以自定义包名不为java.lang的String类，区别包名是可以正常使用的。 包名不为java.lang package com.seven.jvm; public final class String { /** The value is used for character st
一文讲清楚static关键字
static能修饰的地方 静态变量 静态变量: 又称为类变量，也就是说这个变量属于类的，类所有的实例都共享静态变量，可以直接通过类名来访问它；静态变量在内存中只存在一份。 实例变量: 每创建一个实例就会产生一个实例变量，它与该实例同生共死。 静态方法 静态方法在类加载的时候就存在了，它不依赖于任何实
String究竟能存储多少字符？
能存储多少字符，通过以下步骤来看 首先String的length方法返回是int。所以理论上长度一定不会超过int的最大值。 编译器对字符串字面量长度的限制源自Java编译器（如javac）在处理常量池时的实现。编译器源码如下，限制了字符串长度大于等于65535就会编译不通过：// src/jdk.
解决哈希冲突的三种方法
为什么会哈希冲突 我们知道，在使用Map，Set这些集合时，都会重写hashcode方法，但Java中的hashCode方法会将对象映射到一个32位的整数范围（即从-2^31 到 2^31-1）。无论输入数据多么庞大，哈希函数生成的哈希值总是落在这个有限范围内。因此是会存在hash冲突的。 无论哈希
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native