码迷，mamicode.com
首页 > 数据库 > 详细

mybatis连接mysql数据库实现的jdbc功能

时间：2015-05-31 10:59:06      阅读：266      评论：0      收藏：0      [点我收藏+]

标签：

最近公司项目要使用myBatis，自己以前没有接触过，就在网上找到了一些资料研究了些。初步做出了基于myBatis连接mysql数据库的jdbc实现的功能。

employee.java

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

　employeeDao.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package com.org.position.dao;
 
import java.util.List;
 
import com.org.position.model.employee;
 
public interface employeeDao {
   public int countAll();
   public employee findEnterprise(int employeeId);
   public int insertEnterprise(employee emp);
   public int deleteEnterprise(int employeeId);
   public List<employee> getAllEnterprise();
   public int updateEnterprise(employee emp );
   public List<employee> findEnterpriseByExampleIf(employee emp);
    
}

employeeDaoimpal.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
package com.org.position.dao.impal;
 
import java.io.IOException;
import java.io.Reader;
import java.util.List;
 
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
 
import com.org.position.dao.employeeDao;
import com.org.position.model.employee;
 
public class employeeDaoimpal implements employeeDao {
 
    @Override
    public int countAll() {
        String resource="mybaits-config.xml";
        Reader reader=null;
        SqlSessionFactory  ssf=null;
        SqlSession session=null;
        int iCount=0;
        try {
            reader= Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder =new SqlSessionFactoryBuilder();
            ssf=builder.build(reader);
            session=ssf.openSession();
            iCount=session.selectOne("com.org.position.dao.employeeDao.countAll");
        } catch (IOException e) {
            e.printStackTrace();
        }
        finally{
            session.close();
        }
        return iCount;
    }
 
    @Override
    public employee findEnterprise(int employeeId) {
        String resource="mybaits-config.xml";
        Reader reader=null;
        SqlSessionFactory  ssf=null;
        SqlSession session=null;
        employee  emp=null;
        try {
            reader = Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            ssf = builder.build(reader);
            session=ssf.openSession();
            employeeDao empdao=session.getMapper(employeeDao.class);
            emp=empdao.findEnterprise(employeeId);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            session.close();
        }
         
        return emp;
    }
 
    @Override
    public int insertEnterprise(employee emp) {
        String resource="mybaits-config.xml";
        Reader reader=null;
        SqlSessionFactory  ssf=null;
        SqlSession session=null;
        int count=0;
        try {
            reader = Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            ssf = builder.build(reader);
            session=ssf.openSession();
            count=session.insert("com.org.position.dao.employeeDao.insertEnterprise",emp);
            session.commit();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally{
            session.close();
        }
        return count;
    }
 
    @Override
    public int deleteEnterprise(int employeeId) {
        String resource="mybaits-config.xml";
        Reader reader = null;
        SqlSessionFactory ssf=null;
        SqlSession session=null;
        int iCount = 0;
        try {
            reader = Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            ssf = builder.build(reader);
            session=ssf.openSession();
            iCount=session.delete("com.org.position.dao.employeeDao.deleteEnterprise", employeeId);
            session.commit();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            session.close();
        }
         
        return iCount;
    }
 
    @Override
    public List<employee> getAllEnterprise() {
        String resource="mybaits-config.xml";
        Reader reader = null;
        SqlSessionFactory ssf=null;
        SqlSession session=null;
        List<employee> emps = null;
        try {
            reader = Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            ssf = builder.build(reader);
            session=ssf.openSession();
            emps=session.selectList("com.org.position.dao.employeeDao.getAllEnterprise");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally{
            session.close();
        }
        return emps;
    }
 
    @Override
    public int updateEnterprise(employee emp) {
        String resource="mybaits-config.xml";
        Reader reader = null;
        SqlSessionFactory ssf=null;
        SqlSession session=null;
        int iCount = 0;
            try {
                reader = Resources.getResourceAsReader(resource);
                SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
                 
                ssf = builder.build(reader);
                session=ssf.openSession();
                iCount=session.delete("com.org.position.dao.employeeDao.updateEnterprise",emp);
                session.commit();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                session.close();
            }
         
         
        return iCount;
    }
 
    @Override
    public List<employee> findEnterpriseByExampleIf(employee emp) {
        String resource="mybatis-config.xml";
        Reader reader = null;
        SqlSessionFactory ssf=null;
        SqlSession session=null;
        List<employee> emps = null;
        try {
            reader = Resources.getResourceAsReader(resource);
            SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
            ssf = builder.build(reader);
            session=ssf.openSession();
            emps=session.selectList("com.org.position.dao.employeeDao.findEnterpriseByExampleIf",emp);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            session.close();
        }
         
        return emps;
    }
 
}

　employeeDaoMapper.xml

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

　mybaits-config.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
   <environments default="development">
     <environment id="development">
     <transactionManager type="JDBC"></transactionManager>
     <dataSource type="POOLED">
     <property name="driver" value="com.mysql.jdbc.Driver"/>
     <property name="url" value="jdbc:mysql://localhost:3306/test"/>
     <property name="username" value="root"/>
     <property name="password" value="mysql"/>
     </dataSource>
     </environment>
   </environments>
  <mappers>
    <mapper resource="com/org/position/dao/employeeDaoMapper.xml"/>
  </mappers>
</configuration>

　employeeTest.java

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

t_employee.sql

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
/*
SQLyog Ultimate v8.32
MySQL - 5.0.27-community : Database - test
*********************************************************************
*/
 
 
/*!40101 SET NAMES utf8 */;
 
/*!40101 SET SQL_MODE=‘‘*/;
 
/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE=‘NO_AUTO_VALUE_ON_ZERO‘ */;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET utf8 */;
 
USE `test`;
 
/*Table structure for table `t_employee` */
 
DROP TABLE IF EXISTS `t_employee`;
 
CREATE TABLE `t_employee` (
  `employeeid` int(10) NOT NULL COMMENT ‘员工id‘,
  `employeename` varchar(20) NOT NULL COMMENT ‘员工姓名‘,
  `employeesax` varchar(20) default NULL COMMENT ‘员工性别‘,
  `employeepost` varchar(30) NOT NULL COMMENT ‘员工职务‘,
  `employeedepartment` varchar(30) NOT NULL default ‘‘ COMMENT ‘员工所在部门‘,
  PRIMARY KEY  (`employeeid`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
 
/*Data for the table `t_employee` */
 
insert  into `t_employee`(`employeeid`,`employeename`,`employeesax`,`employeepost`,`employeedepartment`) values (1,‘雷浩明‘,‘男‘,‘CEO‘,‘总裁办‘),(2,‘刘军‘,‘男‘,‘执行总裁‘,‘总裁办‘),(3,‘李海涛‘,‘男‘,‘总经理‘,‘总经办‘),(4,‘边肖‘,‘男‘,‘CTO‘,‘技术部‘),(5,‘柳青‘,‘女‘,‘经理‘,‘经营管理部‘),(6,‘高晓梅‘,‘女‘,‘财务‘,‘财务部‘),(7,‘曹舜水‘,‘男‘,‘研发经理‘,‘研发部‘),(8,‘董华‘,‘男‘,‘项目经理‘,‘研发部‘),(9,‘张军华‘,‘男‘,‘产品经理‘,‘产品部‘),(10,‘曾爽‘,‘女‘,‘测试经理‘,‘研发部‘);
 
/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

项目代码结构截图：

技术分享

项目需要的jar包下载地址：mybatis支持jar包下载。

mybatis连接mysql数据库实现的jdbc功能

标签：

原文地址：http://blog.csdn.net/u012151556/article/details/46285317
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！