免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › Java › mybatis连接mysql数据库实现的jdbc功能
最近访问板块 发新帖
查看: 4346 | 回复: 0
打印 上一主题 下一主题

mybatis连接mysql数据库实现的jdbc功能 [复制链接]

nintyuui

论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2015-06-17 09:45 |只看该作者 |倒序浏览
最近公司项目要使用myBatis，自己以前没有接触过，就在网上找到了一些资料研究了些。初步做出了基于myBatis连接mysql数据库的jdbc实现的功能。项目需要的jar包下载地址：http://pan.baidu.com/s/1AWnPc
employee.java
  1. package com.org.position.model;

  3. public class employee {
  4.     private int     employeeId;// 员工id
  5.     private String  employeeName; //员工姓名
  6.     private String  employeeSax; //员工性别
  7.     private String  employeePost; //员工职务
  8.     private String  employeeDepartment; //员工所在部门
  9.      
  10.     public int getEmployeeId() {
  11.         return employeeId;
  12.     }
  13.     public void setEmployeeId(int employeeId) {
  14.         this.employeeId = employeeId;
  15.     }
  16.     public String getEmployeeName() {
  17.         return employeeName;
  18.     }
  19.     public void setEmployeeName(String employeeName) {
  20.         this.employeeName = employeeName;
  21.     }
  22.     public String getEmployeeSax() {
  23.         return employeeSax;
  24.     }
  25.     public void setEmployeeSax(String employeeSax) {
  26.         this.employeeSax = employeeSax;
  27.     }
  28.     public String getEmployeePost() {
  29.         return employeePost;
  30.     }
  31.     public void setEmployeePost(String employeePost) {
  32.         this.employeePost = employeePost;
  33.     }
  34.     public String getEmployeeDepartment() {
  35.         return employeeDepartment;
  36.     }
  37.     public void setEmployeeDepartment(String employeeDepartment) {
  38.         this.employeeDepartment = employeeDepartment;
  39.     }
  40.      
  41. }
复制代码
employeeDao.java
  1. package com.org.position.dao;


  4. import java.util.List;

  6. import com.org.position.model.employee;

  8. public interface employeeDao {
  9.    public int countAll();
  10.    public employee findEnterprise(int employeeId);
  11.    public int insertEnterprise(employee emp);
  12.    public int deleteEnterprise(int employeeId);
  13.    public List<employee> getAllEnterprise();
  14.    public int updateEnterprise(employee emp );
  15.    public List<employee> findEnterpriseByExampleIf(employee emp);
  16.    
  17. }
复制代码
employeeDaoimpal.java
  1. package com.org.position.dao.impal;

  3. import java.io.IOException;
  4. import java.io.Reader;
  5. import java.util.List;

  7. import org.apache.ibatis.io.Resources;
  8. import org.apache.ibatis.session.SqlSession;
  9. import org.apache.ibatis.session.SqlSessionFactory;
  10. import org.apache.ibatis.session.SqlSessionFactoryBuilder;

  12. import com.org.position.dao.employeeDao;
  13. import com.org.position.model.employee;

  15. public class employeeDaoimpal implements employeeDao {

  17.     @Override
  18.     public int countAll() {
  19.         String resource="mybaits-config.xml";
  20.         Reader reader=null;
  21.         SqlSessionFactory  ssf=null;
  22.         SqlSession session=null;
  23.         int iCount=0;
  24.         try {
  25.             reader= Resources.getResourceAsReader(resource);
  26.             SqlSessionFactoryBuilder builder =new SqlSessionFactoryBuilder();
  27.             ssf=builder.build(reader);
  28.             session=ssf.openSession();
  29.             iCount=session.selectOne("com.org.position.dao.employeeDao.countAll");
  30.         } catch (IOException e) {
  31.             e.printStackTrace();
  32.         }
  33.         finally{
  34.             session.close();
  35.         }
  36.         return iCount;
  37.     }

  39.     @Override
  40.     public employee findEnterprise(int employeeId) {
  41.         String resource="mybaits-config.xml";
  42.         Reader reader=null;
  43.         SqlSessionFactory  ssf=null;
  44.         SqlSession session=null;
  45.         employee  emp=null;
  46.         try {
  47.             reader = Resources.getResourceAsReader(resource);
  48.             SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  49.             ssf = builder.build(reader);
  50.             session=ssf.openSession();
  51.             employeeDao empdao=session.getMapper(employeeDao.class);
  52.             emp=empdao.findEnterprise(employeeId);
  53.         } catch (IOException e) {
  54.             // TODO Auto-generated catch block
  55.             e.printStackTrace();
  56.         }finally{
  57.             session.close();
  58.         }
  59.          
  60.         return emp;
  61.     }

  63.     @Override
  64.     public int insertEnterprise(employee emp) {
  65.         String resource="mybaits-config.xml";
  66.         Reader reader=null;
  67.         SqlSessionFactory  ssf=null;
  68.         SqlSession session=null;
  69.         int count=0;
  70.         try {
  71.             reader = Resources.getResourceAsReader(resource);
  72.             SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  73.             ssf = builder.build(reader);
  74.             session=ssf.openSession();
  75.             count=session.insert("com.org.position.dao.employeeDao.insertEnterprise",emp);
  76.             session.commit();
  77.         } catch (IOException e) {
  78.             // TODO Auto-generated catch block
  79.             e.printStackTrace();
  80.         }
  81.         finally{
  82.             session.close();
  83.         }
  84.         return count;
  85.     }

  87.     @Override
  88.     public int deleteEnterprise(int employeeId) {
  89.         String resource="mybaits-config.xml";
  90.         Reader reader = null;
  91.         SqlSessionFactory ssf=null;
  92.         SqlSession session=null;
  93.         int iCount = 0;
  94.         try {
  95.             reader = Resources.getResourceAsReader(resource);
  96.             SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  97.             ssf = builder.build(reader);
  98.             session=ssf.openSession();
  99.             iCount=session.delete("com.org.position.dao.employeeDao.deleteEnterprise", employeeId);
  100.             session.commit();
  101.         } catch (IOException e) {
  102.             // TODO Auto-generated catch block
  103.             e.printStackTrace();
  104.         }finally{
  105.             session.close();
  106.         }
  107.          
  108.         return iCount;
  109.     }

  111.     @Override
  112.     public List<employee> getAllEnterprise() {
  113.         String resource="mybaits-config.xml";
  114.         Reader reader = null;
  115.         SqlSessionFactory ssf=null;
  116.         SqlSession session=null;
  117.         List<employee> emps = null;
  118.         try {
  119.             reader = Resources.getResourceAsReader(resource);
  120.             SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  121.             ssf = builder.build(reader);
  122.             session=ssf.openSession();
  123.             emps=session.selectList("com.org.position.dao.employeeDao.getAllEnterprise");
  124.         } catch (IOException e) {
  125.             // TODO Auto-generated catch block
  126.             e.printStackTrace();
  127.         }
  128.         finally{
  129.             session.close();
  130.         }
  131.         return emps;
  132.     }

  134.     @Override
  135.     public int updateEnterprise(employee emp) {
  136.         String resource="mybaits-config.xml";
  137.         Reader reader = null;
  138.         SqlSessionFactory ssf=null;
  139.         SqlSession session=null;
  140.         int iCount = 0;
  141.             try {
  142.                 reader = Resources.getResourceAsReader(resource);
  143.                 SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  144.                  
  145.                 ssf = builder.build(reader);
  146.                 session=ssf.openSession();
  147.                 iCount=session.delete("com.org.position.dao.employeeDao.updateEnterprise",emp);
  148.                 session.commit();
  149.             } catch (IOException e) {
  150.                 // TODO Auto-generated catch block
  151.                 e.printStackTrace();
  152.             }finally{
  153.                 session.close();
  154.             }
  155.          
  156.          
  157.         return iCount;
  158.     }

  160.     @Override
  161.     public List<employee> findEnterpriseByExampleIf(employee emp) {
  162.         String resource="mybatis-config.xml";
  163.         Reader reader = null;
  164.         SqlSessionFactory ssf=null;
  165.         SqlSession session=null;
  166.         List<employee> emps = null;
  167.         try {
  168.             reader = Resources.getResourceAsReader(resource);
  169.             SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
  170.             ssf = builder.build(reader);
  171.             session=ssf.openSession();
  172.             emps=session.selectList("com.org.position.dao.employeeDao.findEnterpriseByExampleIf",emp);
  173.         } catch (IOException e) {
  174.             // TODO Auto-generated catch block
  175.             e.printStackTrace();
  176.         }finally{
  177.             session.close();
  178.         }
  179.          
  180.         return emps;
  181.     }

  183. }
复制代码
employeeDaoMapper.xml
  1. <?xml version="1.0" encoding="UTF-8" ?>   

  3. <!DOCTYPE mapper   
  4. PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
  5. "http://ibatis.apache.org/dtd/ibatis-3-mapper.dtd">
  6. <mapper  namespace="com.org.position.dao.employeeDao">
  7.   <resultMap type="com.org.position.model.employee" id="empResultMap">
  8.     <id property="employeeId" column="employeeId"/>
  9.     <result property="employeeName" column="employeeName" />
  10.     <result property="employeeSax" column="employeeSax"/>
  11.     <result property="employeePost" column="employeePost"/>
  12.      <result property="employeeDepartment" column="employeeDepartment"/>
  13.   </resultMap>
  14.    <select id="findEnterpriseByExampleIf" parameterType="com.org.position.model.employee"  resultMap="empResultMap">
  15.       select * from employee where 1=1
  16.      <if test="employeed !=null">
  17.          and employeeId=#{employeeId}
  18.      </if>
  19.        <if test="employeename!=null">
  20.          and employeeName=#{employeeName}
  21.        </if>
  22.         <if test="employeesax! =null">
  23.          and employeeSax=#{employeeSax}
  24.         </if>
  25.         <if test="employeepost!=null">
  26.          and employeePost=#{employeePost}
  27.         </if>
  28.         <if test="employeedepartment! =null">
  29.          and  employeeDepartment=#{employeeDepartment}
  30.         </if>
  31.    </select>
  32.   
  33.    <select id="countAll"  resultType="int">
  34.        select count(*) from t_employee
  35.    </select>
  36.   <!--   根据id查询对应的数据信息 -->
  37.    <select id="findEnterprise" parameterType="int" resultType="com.org.position.model.employee">
  38.      select * from t_employee where employeeId=#{employeeId}
  39.    </select>
  40.     <!--    查询所有 数据 -->
  41.    <select id="getAllEnterprise" resultType="com.org.position.model.employee">
  42.       select * from t_employee
  43.    </select>
  44.         <!-- 添加数据信息 -->
  45.    <insert id="insertEnterprise" parameterType="com.org.position.model.employee">
  46.         insert into  t_employee(employeeId,employeeName,employeeSax,employeePost,employeeDepartment)
  47.         values (#{employeeId},#{employeeName},#{employeeSax},#{employeePost},#{employeeDepartment})
  48.    </insert>
  49.         <!-- 更新数据信息 -->
  50.    <update id="updateEnterprise" parameterType="com.org.position.model.employee">
  51.      update t_employee set employeeName=#{employeeName},employeeSax=#{employeeSax},employeePost=#{employeePost},employeeDepartment=#{employeeDepartment}
  52.      where employeeId=#{employeeId}
  53.    </update>
  54.     <!-- 删除数据信息 -->
  55.    <delete id="deleteEnterprise" parameterType="com.org.position.model.employee">
  56.     delete from t_employee where employeeId=#{employeeId}
  57.    
  58.    </delete>
  59. </mapper>
复制代码
mybaits-config.xm
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  3. "http://mybatis.org/dtd/mybatis-3-config.dtd">
  4. <configuration>
  5.    <environments default="development">
  6.      <environment id="development">
  7.      <transactionManager type="JDBC"></transactionManager>
  8.      <dataSource type="POOLED">
  9.      <property name="driver" value="com.mysql.jdbc.Driver"/>
  10.      <property name="url" value="jdbc:mysql://localhost:3306/test"/>
  11.      <property name="username" value="root"/>
  12.      <property name="password" value="mysql"/>
  13.      </dataSource>
  14.      </environment>
  15.    </environments>
  16.   <mappers>
  17.     <mapper resource="com/org/position/dao/employeeDaoMapper.xml"/>
  18.   </mappers>
  19. </configuration>
复制代码
mybaits-config.xml
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  3. "http://mybatis.org/dtd/mybatis-3-config.dtd">
  4. <configuration>
  5.    <environments default="development">
  6.      <environment id="development">
  7.      <transactionManager type="JDBC"></transactionManager>
  8.      <dataSource type="POOLED">
  9.      <property name="driver" value="com.mysql.jdbc.Driver"/>
  10.      <property name="url" value="jdbc:mysql://localhost:3306/test"/>
  11.      <property name="username" value="root"/>
  12.      <property name="password" value="mysql"/>
  13.      </dataSource>
  14.      </environment>
  15.    </environments>
  16.   <mappers>
  17.     <mapper resource="com/org/position/dao/employeeDaoMapper.xml"/>
  18.   </mappers>
  19. </configuration>
复制代码
employeeTest.java
  1. package com.org.position.test;

  3. import java.util.List;

  5. import com.org.position.dao.employeeDao;
  6. import com.org.position.dao.impal.employeeDaoimpal;
  7. import com.org.position.model.employee;

  9. public class employeeTest {
  10.      
  11.     public static void testAddEmp(){
  12.         employee emp=new employee();
  13.         employeeDao dao=new employeeDaoimpal();
  14.         emp.setEmployeeId(11);
  15.         emp.setEmployeeName("爽");
  16.         emp.setEmployeeSax("女");
  17.         emp.setEmployeePost("测试经理");
  18.         emp.setEmployeeDepartment("研发部");
  19.         int count =dao.insertEnterprise(emp);
  20.         if (count==1) {
  21.             System.out.println("员工信息录入成功！");
  22.         }else {
  23.             System.out.println("员工信息录入失败！");
  24.         }
  25.          
  26.          
  27.     }
  28.      
  29.     public static void testUpdateEmp(){
  30.         employee emp=new employee();
  31.         emp.setEmployeeId(1);
  32.         emp.setEmployeeName("雷浩明");
  33.         emp.setEmployeeSax("男");
  34.         emp.setEmployeePost("CEO");
  35.         emp.setEmployeeDepartment("总裁办");
  36.         employeeDao dao=new employeeDaoimpal();
  37.         int count =dao.updateEnterprise(emp);
  38.         if (count==1) {
  39.             System.out.println("员工信息修改成功！");
  40.         }else {
  41.             System.out.println("员工信息修改失败！");
  42.         }
  43.          
  44.     }
  45.     public static void testSelectEmp(){
  46.          
  47.     }
  48.     public static void testDeleteEmp(){
  49.         employeeDao dao =new employeeDaoimpal();
  50.         int count = dao.deleteEnterprise(11);
  51.         if(count == 1){
  52.             System.out.println("员工信息删除成功");
  53.         }else {
  54.             System.out.println("员工信息删除失败");
  55.         }
  56.     }
  57.      
  58.     public static void testGetCount(){
  59.         employeeDao dao =new employeeDaoimpal();
  60.         System.out.println("共有"+dao.countAll()+"名员工");
  61.     }
  62.      
  63.     public static void testGetEmpById(){
  64.         employeeDao dao =new employeeDaoimpal();
  65.         employee emp=dao.findEnterprise(1);
  66.         System.out.println("职务是:"+emp.getEmployeePost()+"  所在部门:"+emp.getEmployeeDepartment());
  67.     }
  68.      
  69.     public static void testGetAll(){
  70.         employeeDao dao =new employeeDaoimpal();
  71.         List<employee> emps = dao.getAllEnterprise();
  72.         System.out.println("西安涯创信息技术有限公司员工明细");
  73.         System.out.println("---------------------------");
  74.         System.out.println("员工编号\t员工姓名\t员工职位\t所在部门");
  75.         for (employee emp : emps) {
  76.             System.out.println(emp.getEmployeeId()+"\t"+emp.getEmployeeName()+"\t"+emp.getEmployeePost()+"\t"+emp.getEmployeeDepartment());
  77.         }
  78.     }
  79.      
  80.     public static void main(String[] args) {
  81.          //testAddEmp();
  82.          //testUpdateEmp();
  83.          //testDeleteEmp();
  84.          //testGetCount();
  85.          //testGetEmpById();
  86.            testGetAll();
  87.     }
  88.      
  89. }
复制代码
t_employee.sql
  1. /*
  2. SQLyog Ultimate v8.32
  3. MySQL - 5.0.27-community : Database - test
  4. *********************************************************************
  5. */


  8. /*!40101 SET NAMES utf8 */;

  10. /*!40101 SET SQL_MODE=''*/;

  12. /*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
  13. /*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
  14. /*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
  15. /*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
  16. CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET utf8 */;

  18. USE `test`;

  20. /*Table structure for table `t_employee` */

  22. DROP TABLE IF EXISTS `t_employee`;

  24. CREATE TABLE `t_employee` (
  25.   `employeeid` int(10) NOT NULL COMMENT '员工id',
  26.   `employeename` varchar(20) NOT NULL COMMENT '员工姓名',
  27.   `employeesax` varchar(20) default NULL COMMENT '员工性别',
  28.   `employeepost` varchar(30) NOT NULL COMMENT '员工职务',
  29.   `employeedepartment` varchar(30) NOT NULL default '' COMMENT '员工所在部门',
  30.   PRIMARY KEY  (`employeeid`)
  31. ) ENGINE=MyISAM DEFAULT CHARSET=utf8;

  33. /*Data for the table `t_employee` */

  35. insert  into `t_employee`(`employeeid`,`employeename`,`employeesax`,`employeepost`,`employeedepartment`) values (1,'雷浩明','男','CEO','总裁办'),(2,'刘军','男','执行总裁','总裁办'),(3,'李海涛','男','总经理','总经办'),(4,'边肖','男','CTO','技术部'),(5,'柳青','女','经理','经营管理部'),(6,'高晓梅','女','财务','财务部'),(7,'曹舜水','男','研发经理','研发部'),(8,'董华','男','项目经理','研发部'),(9,'张军华','男','产品经理','产品部'),(10,'曾爽','女','测试经理','研发部');

  37. /*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
  38. /*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
  39. /*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
  40. /*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
复制代码
数据库, mysql
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP