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,这个文件虽然是自己键的,但也需要到文档中将头复制过来-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">,sql语句就写在该文件中
6、编写代码获取配置文件资源
具体操作如下:
创建mybatis-config.xml文件
属性文件jdbc.properties
driver=com.microsoft.sqlserver.jdbc.SQLServerDriver url=jdbc:sqlserver://127.0.0.1:1434;Database=Users username=sa password=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文件
insert into tb_users values(#{userName},#{password},#{trueName},#{email},#{phone},#{sex},#{group_id}) update tb_users set password=#{password},phone=#{phone} where id=#{id} 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(); // 查询全部对象 Listlist = 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("sdfsds@e.com"); user.setPhone("12093234322342"); user.setSex("男"); 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对数据库的简单的增删改查操作
上一篇: jQuery.ajaxSetup()函数的用法实例详解
下一篇: php循环输出表格错位的问题