Mybatis入门概述及第一个Mybatis实例实现增删改查(四)

2015-07-24 09:22:39 · 作者: · 浏览: 2
commit() ; } finally { session.close(); } } /** * 更改 */ public static void updateEmployeer(Employeer employeer){ SqlSession session = null; try { session = sqlSessionFactory.openSession(); session.update("com.mucfc.model.EmployeerMapper.updateEmployeer",employeer); session.commit() ; } finally { session.close(); } } public static void main(String[] args) { Employeer employeer1=new Employeer(); employeer1.setEmployeer_name("李四"); employeer1.setEmployeer_age(23); employeer1.setEmployeer_department("产品一部"); employeer1.setEmployeer_worktype("开发工程师"); Employeer employeer2=new Employeer(); employeer2.setEmployeer_name("张三"); employeer2.setEmployeer_age(30); employeer2.setEmployeer_department("产品二部"); employeer2.setEmployeer_worktype("测试工程师"); Employeer employeer3=new Employeer(); employeer3.setEmployeer_name("小王"); employeer3.setEmployeer_age(22); employeer3.setEmployeer_department("产品三部"); employeer3.setEmployeer_worktype("数据分析师"); Employeer employeer4=new Employeer(); employeer4.setEmployeer_name("明明"); employeer4.setEmployeer_age(22); employeer4.setEmployeer_department("财会部"); employeer4.setEmployeer_worktype("财务人员"); //插入 addEmployeer(employeer1); addEmployeer(employeer2); addEmployeer(employeer3); addEmployeer(employeer4); //查找 findEmployeerById(1); //删除 deleteEmployeer(1); //更改 employeer2.setEmployeer_id(2); employeer2.setEmployeer_age(21); employeer2.setEmployeer_department("产品三部"); updateEmployeer(employeer2); } }
下面一个一个来分析

?

(1)插入测试

函数 :

?

/**
	 * 增加
	 */
	public static void addEmployeer(Employeer employeer){
		SqlSession session = null;
		try {
			session = sqlSessionFactory.openSession();
			 //返回值是记录条数  
            int resultCount = session.insert("com.mucfc.model.EmployeerMapper.addEmployeer", employeer );  
            System.out.printf("当前插入的employeer_id :%d    当前插入数据库中条数:%d " , employeer.getEmployeer_id() ,resultCount);  //获取插入对象的id  
            System.out.println("");
            session.commit() ;  		
		} finally {
			session.close();
		}
		
	}

调用

?

?

		//插入
     	addEmployeer(employeer1);
		addEmployeer(employeer2);
		addEmployeer(employeer3);
		addEmployeer(employeer4);


?

\

数据库中结果:

\

(2)查找测试,接上面插入测试:

函数:

?

	/**
	 * 查找
	 */
	public static void findEmployeerById(int id) {
		SqlSession session = null;
		try {
			session = sqlSessionFactory.openSession();
			Employeer employeer = (Employeer) session.selectOne(
					"com.mucfc.model.EmployeerMapper.findEmployeerByID", 1);
			if (employeer == null)
				System.out.println("null");
			else
				System.out.println(employeer);
		} finally {
			session.close();
		}
	}

调用:

?

?

//查找
		findEmployeerById(1);
结果

?

\

(3)删除测试,接上面

其中函数:

?

	/**
	 * 删除
	 * 
	 */
	public static void deleteEmployeer(int id){
		SqlSession session = null;
		try {
			session = sqlSessionFactory.openSession();
			 //返回值是记录条数  
			 int resultCount=session.delete("com.mucfc.model.EmployeerMapper.deleteEmployeer",id); 
			  System.out