ibatis 完美例子 一对多 批处理 事务 和 spring struts2集成

package com.jlins.dao; import java.sql.SQLException; import java.util.Date; import java.util.List; import com.ibatis.sqlmap.client.SqlMapClient; import com.jlins.IbatisClient; import com.jlins.bean.Student; import com.jlins.bean.Teacher; public class IbatisDAO implements IStudentDAO{ SqlMapClient client = null; public void addStudent(Student student) { client=new IbatisClient().getSqlMapInstance(); try { client.insert("insertStudent",student); } catch (SQLException e) { e.printStackTrace(); } } public void addStudentBySequence(Student student) { //oracle创建序列的方法 create sequence studentPKSequence start with 1 increment by 1; //1.从数据库序列中获取主键值 //2.往student表中插入记录 client=new IbatisClient().getSqlMapInstance(); try { client.insert("insertStudentBySquence",student); } catch (SQLException e) { e.printStackTrace(); } } public void deleteStudentById(int id) { client=new IbatisClient().getSqlMapInstance(); try { System.out.println(client.delete("deleteStudentById", 6)); } catch (SQLException e) { e.printStackTrace(); } } public Student queryStudentById(int id) { client=new IbatisClient().getSqlMapInstance(); Student student =null; try { student =(Student) client.queryForObject("selectStudentById", 1); } catch (SQLException e) { e.printStackTrace(); } return student; } public List<Student> queryAllStudent() { List<Student> studentlist=null; client=new IbatisClient().getSqlMapInstance(); try { studentlist=client.queryForList("selectAllStudent"); System.out.println(studentlist.size()); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return studentlist; } public List<Student> queryStudentByName(String name) { List<Student> studentlist=null; client=new IbatisClient().getSqlMapInstance(); try { studentlist =client.queryForList("selectStudentByName",name); System.out.println(studentlist.size()); } catch (SQLException e) { e.printStackTrace(); } return studentlist; } public void updateStudent(Student student) { client=new IbatisClient().getSqlMapInstance(); try { client.update("updateStudent", student); } catch (SQLException e) { e.printStackTrace(); } } public void batchOneToMany() { try { long start =System.currentTimeMillis(); //只有添加了事物之后 ibatis批处理才会执行 //哈哈 一对多的问题成功的解决了插入 //批处理关联一万条才一秒多 哈哈 client.startTransaction(); client.startBatch(); Student student =new Student(); student.setBirth(new Date()); student.setId(6); student.setMajor("i love it"); student.setScore(99); student.setSname("jlins6"); client.insert("insertStudentBySquence",student); for(int i=0;i<15555;i++){ Teacher teacher=new Teacher(); teacher.setId(i); teacher.setStudent(student); client.insert("insertTeacher",teacher); } client.executeBatch(); client.commitTransaction(); client.endTransaction(); long time=System.currentTimeMillis()-start; System.out.println(time); } catch (SQLException e) { e.printStackTrace(); }finally{ } } public List<Teacher> queryTeacherById(int id) { List<Teacher> teacherlist=null; client=new IbatisClient().getSqlMapInstance(); try { long start=System.currentTimeMillis(); // teacherlist=client.queryForList("selectTeacherById", id); //查询teacher关联student查询用接近20秒 // teacherlist=client.queryForList("selectAllTeacher"); //只查询teacher不关联查询 2万条记录只用2秒多 // teacherlist=client.queryForList("selectAllTeacherOnly"); //使用左查询链接 只需要 不到3秒就可以 teacherlist=client.queryForList("selectAllTeacherLeft"); System.out.println(teacherlist.size()); System.out.println(System.currentTimeMillis()-start); } catch (SQLException e) { e.printStackTrace(); } return teacherlist; } public static void main(String args[]){ IStudentDAO dao =new IbatisDAO(); //1. /* for(Student student:dao.queryAllStudent()){ System.out.println(student.getId()); System.out.println(student.getMajor()); System.out.println(student.getSname()); System.out.println(student.getBirth()); System.out.println(student.getScore()); }*/ //2. /* Student student =dao.queryStudentById(1); System.out.println(student.getId()); System.out.println(student.getMajor()); System.out.println(student.getSname()); System.out.println(student.getBirth()); System.out.println(student.getScore());*/ //3. /* Student student =new Student(); student.setBirth(new Date()); student.setId(6); student.setMajor("i love it"); student.setScore(99); student.setSname("jlins6"); dao.addStudent(student);*/ //4. /* dao.deleteStudentById(6);*/ //5. /* Student student =new Student(); student.setBirth(new Date()); student.setId(6); student.setMajor("i love that"); student.setScore(999); student.setSname("jlins6_update"); dao.updateStudent(student);*/ //6. /* for(Student student:dao.queryStudentByName("jlins")){ System.out.println(student.getId()); System.out.println(student.getMajor()); System.out.println(student.getSname()); System.out.println(student.getBirth()); System.out.println(student.getScore()); } */ //7. /* Student student =new Student(); student.setBirth(new Date()); student.setId(6); student.setMajor("i love it"); student.setScore(99); student.setSname("jlins6"); dao.addStudentBySequence(student); //打印出来的是更新以后的id很是个不错 System.out.println(student.getId());*/ //一对多关系先存储一的一端，然后批处理存储多的一端 //?? 问题来了 一的一段和多的一段都采用数据库自增的方式，批处理如何能正确的确定id //8. // dao.batchOneToMany(); // dao.queryTeacherById(50); for(Teacher teacher:dao.queryTeacherById(50)){ System.out.println(teacher.getId()); System.out.println(teacher.getStudent().getMajor()); System.out.println(teacher.getStudent().getSname()); System.out.println(teacher.getStudent().getBirth()); System.out.println(teacher.getStudent().getScore()); } } }