MyBatis连接SQLServer数据库

MyBatis与Hibernate都是持久层框架，其实MyBatis在早起的版本名叫IBatis，目前和Hibernate用的最多的持久层框架 什么是MyBatis？ MyBatis 是支持普通 SQL 查询,存储过程和高级映射的优秀持久层框架。MyBatis 消除 了几乎所有的 JDBC 代码和参数的手工设置以

MyBatis与Hibernate都是持久层框架，其实MyBatis在早起的版本名叫IBatis，目前和Hibernate用的最多的持久层框架

什么是MyBatis？

MyBatis 是支持普通 SQL 查询,存储过程和高级映射的优秀持久层框架。MyBatis 消除 了几乎所有的 JDBC 代码和参数的手工设置以及结果集的检索。MyBatis 使用简单的 XML 或注解用于配置和原始映射,将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java 对象)映射成数据库中的记录。

其他的就不用多说了，直接进入正题用代码说话比较实在

要使用MyBatis这个持久层框架，必须要到网上去下载框架包http://code.google.com/p/mybatis/downloads/detail?name=mybatis-3.2.3.zip

1、在MyEclipse中创建一个Java工程，工程名随便，自己喜欢就行

2、将MyBatis的jar包和数据库的驱动包导入工程

3、创建mybatis-config.xml配置文件，配置文件的说明在下载的文件里面有英文版的，在官网上面也有中文版http://mybatis.github.io/mybatis-3/zh/index.html，可以到官网的帮助文档中将mybatis-config.xml的头不复制到文件中

这样就有了提示功能，当然不要也行，只要你能记住，都无所谓的

4、创建实体类，我这里用的Users类，实体类对应数据库中的字段名

5、创建与类名相对应的xml，如Users.xml，这个文件虽然是自己键的，但也需要到文档中将头复制过来<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
“http://mybatis.org/dtd/mybatis-3-mapper.dtd”>，sql语句就写在该文件中

6、编写代码获取配置文件资源

具体操作如下：

创建mybatis-config.xml文件

<?xml version="1.0" encoding="UTF-8"?>	<!---ecms -ecms  引入属性文件 -->							<!---ecms -ecms  事务管理器 -->						<!---ecms -ecms  配置数据源 -->																										<!---ecms -ecms  配置映射资源文件 -->				

属性文件jdbc.properties

driver=com.microsoft.sqlserver.jdbc.SQLServerDriverurl=jdbc:sqlserver://127.0.0.1:1434;Database=Usersusername=sapassword=xiao(lao&hu

创建Users.java类

package com.tenghu.object;import java.io.Serializable;/** * 用户实体类 * @author xiaolaohu * */public class Users implements Serializable{	//id	private int id;	//用户名	private String userName;	//密码	private String password;	//真实姓名	private String trueName;	//邮件	private String email;	//电话号码	private String phone;	//性别	private String sex;	//用户组	private int group_id;	public int getId() {		return id;	}	public void setId(int id) {		this.id = id;	}	public String getUserName() {		return userName;	}	public void setUserName(String userName) {		this.userName = userName;	}	public String getPassword() {		return password;	}	public void setPassword(String password) {		this.password = password;	}	public String getTrueName() {		return trueName;	}	public void setTrueName(String trueName) {		this.trueName = trueName;	}	public String getEmail() {		return email;	}	public void setEmail(String email) {		this.email = email;	}	public String getPhone() {		return phone;	}	public void setPhone(String phone) {		this.phone = phone;	}	public String getSex() {		return sex;	}	public void setSex(String sex) {		this.sex = sex;	}	public int getGroup_Id() {		return group;	}	public void setGroup(int group_id) {		this.group_id= group_id;	}	public Users() {	}}

创建Users.xml文件

<?xml version="1.0" encoding="UTF-8"?>    	<!---ecms -ecms  查询全部用户 -->  	  		select * from tb_users  	  	<!---ecms -ecms  按照ID查询 -->  	  		select * from tb_users where id=#{id}  	  	<!---ecms -ecms  添加用户 -->  	  		insert into tb_users values(#{userName},#{password},#{trueName},#{email},#{phone},#{sex},#{group_id})  	  	<!---ecms -ecms  修改用户 -->  	  		update tb_users set password=#{password},phone=#{phone} where id=#{id}  	  	<!---ecms -ecms  删除用户 -->  	  		delete  tb_users where id=#{id}  	   

创建MyBatisUtil.java工具类

package com.tenghu.util;import java.io.IOException;import java.io.InputStream;import org.apache.ibatis.io.Resources;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;/** * 工具类 * */public class MyBatisUtil {	//创建SqlSessionFactory对象	private static SqlSessionFactory factory;	static{		try {			//获取配置文件资源			InputStream inputStream=Resources.getResourceAsStream("mybatis-config.xml");			//获取SqlSessionFactory对象			factory=new SqlSessionFactoryBuilder().build(inputStream);		} catch (IOException e) {			e.printStackTrace();		}	}		/**	 * 获取SqlSession对象	 */	public static SqlSession getSqlSession(){		return factory.openSession();	}		/**	 * 关闭SqlSession对象	 */	public static void closeSqlSession(SqlSession session){		if(null!=session){			//关闭Sqlsession对象			session.close();		}		session=null;	}}

编写测试类Test.java

测试获取所有数据：

public static void main(String[] args) {		// 获取SqlSession对象		SqlSession session = MyBatisUtil.getSqlSession();		// 查询全部对象		List list = session.selectList("com.tenghu.object.Users.queryUsers");		System.out.println(list.size());		//关闭SqlSession对象		MyBatisUtil.closeSqlSession(session);	}

测试根据ID获取数据

public static void main(String[] args) {		// 获取SqlSession对象		SqlSession session = MyBatisUtil.getSqlSession();		// 查询单个对象		Users user=session.selectOne("com.tenghu.object.Users.queryUsersId", 4);		System.out.println(user.getId()+"\t"+user.getUserName());		//关闭SqlSession对象		MyBatisUtil.closeSqlSession(session);	}

添加用户：

public static void main(String[] args) {		// 获取SqlSession对象		SqlSession session = MyBatisUtil.getSqlSession();		Users user = new Users();		user.setUserName("xinxin");		user.setPassword("mimimi");		user.setTrueName("信息");		user.setEmail("[email protected]");		user.setPhone("12093234322342");		user.set<strong style="color:transparent">本文来源gao@daima#com搞(%代@#码@网&</strong>Sex("男"); 		user.setGroup_id(1);		session.insert("com.tenghu.object.Users.insertUsers", user);		//提交		session.commit();		// 关闭SqlSession对象		MyBatisUtil.closeSqlSession(session);	}

修改用户：

public static void main(String[] args) {		// 获取SqlSession对象		SqlSession session = MyBatisUtil.getSqlSession();		Users user = new Users();		user.setId(11);		user.setPassword("hahahaha");		user.setPhone("3243223242");		session.update("com.tenghu.object.Users.updateUsers", user);		//提交		session.commit();		// 关闭SqlSession对象		MyBatisUtil.closeSqlSession(session);	}

删除用户：

public static void main(String[] args) {		// 获取SqlSession对象		SqlSession session = MyBatisUtil.getSqlSession();		Users user = new Users();		user.setId(11);		session.delete("com.tenghu.object.Users.deleteUsers", user);		//提交		session.commit();		// 关闭SqlSession对象		MyBatisUtil.closeSqlSession(session);	}

这样就完成的使用MyBatis对数据库的简单的增删改查操作

喜欢 (0)赏

[搞代码]

分享 (0)