标签:
一、数据库表SQL,参见 http://my.oschina.net/u/1757476/blog/497420 文章中的建表SQL语句。
二、下面以程序实例介绍MyBatis的使用
第一步:创建Java工程
使用eclipse创建一个Java工程,jdk 1.7(可使用其他版本)
第二步:
导入jar包,包括mybatis核心包、依赖包以及数据库启动
ojdbc6.jar 是数据库驱动
第三步:设置log4j.properties
在classpath下创建source folder:config/log4j.properties。MyBatis默认使用log4j作为输出日志信息。配置如下:
# Global logging configuration log4j.rootLogger=DEBUG, stdout # Console output... log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n
第四步:在上述的config建立MyBatis核心配置文件:SqlMapConfig.xml,如下(配置 数据源、事务管理):
<?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> <!-- <properties resource=""></properties> --> <!-- 配置mybatis的运行环境 --> <environments default="development"> <environment id="development"> <!-- 事务管理 --> <transactionManager type="JDBC" /> <!-- 配置数据库连接池 --> <dataSource type="POOLED"> <!-- MySql DB --> <!-- <property name="driver" value="com.mysql.jdbc.Driver" /> <property name="url" value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8" /> <property name="username" value="root" /> <property name="password" value="mysql" /> --> <!-- Oracle DB --> <property name="driver" value="oracle.jdbc.driver.OracleDriver" /> <property name="url" value="jdbc:oracle:thin:@127.0.0.1:1521:orcl" /> <property name="username" value="dog" /> <property name="password" value="dog" /> </dataSource> </environment> </environments> <!-- mapper Config,指定sql映射文件 --> <!-- <mappers> <mapper resource="UserMapper.xml"/> </mappers> --> </configuration>
第五步:Po类
Po类作为MyBatis进行sql映射使用,po类通常与数据库表对应,User.java如下:
public class User { private int userId; private String username;// 用户姓名 private String sex;// 性别 private Date birthday;// 出生日期 private String address;// 地址 private String detail;// 详细信息 private Float score;// 成绩 //getter and setter }
第六步:sql映射文件
在classpath下建立source folder:mapperConfig/userMapper.xml sql映射文件,如下:
namespace:命名空间,用于隔离sql语句,后面会讲另一层非常重要的作用。
parameterType:定义输入到sql中的映射类型,#{userId} 表示设置占位符并将userId变量传入sql中。
resultType:定义结果映射类型。
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="test"> <!-- 将定义select理解为一个sql,这个sql对应statement,这时可以将sql的id理解为statement的id --> <!-- 根据UserId查询单个用户信息 --> <select id="findUserById" parameterType="java.lang.Integer" resultType="mybatis.model.User"> select * from users where userId = #{userId} </select> <!-- 用户添加 --> <insert id="insertUser" parameterType="mybatis.model.User"> <!-- keyProperty指定主键映射的pojo对象的属性 order 指selectKey的执行顺序,MySql设置为after, oracle设置为before,因为oracle要先生成Sequence 而在实际使用主键时,MySql使用uuid() 即 SELECT UUID() --> <selectKey keyProperty="userId" order="BEFORE" resultType="java.lang.Integer"> <!-- Mysql: select last_insert_ID() --> <!-- Oracle:必须要先取得Sequence的Nextval,放入pojo中,然后执行insert操作。否则,自增长主键会变成+2,而不是+1 --> select seq_userId.Nextval from dual </selectKey> insert into users (userId, username, birthday, sex, address, detail, score) values (#{userId}, #{username}, #{birthday}, #{sex}, #{address}, #{detail}, #{score}) </insert> <!-- 用户修改--> <update id="updateUserById" parameterType="mybatis.model.User"> update users set username = #{username}, birthday = #{birthday}, sex = #{sex}, address = #{address}, detail = #{detail}, score = #{score} where userId = #{userId} </update> <!-- 用户删除--> <delete id="deleteUserById" parameterType="java.lang.Integer"> delete from users where userId = #{userId} </delete> </mapper>
第七步:将UserMapper.xml添加到SqlMapConfig.xml
<mappers> <mapper resource="UserMapper.xml"/> </mappers>
第八步:编写程序
//查询 public class Mybatis_Select { public static void main(String[] args) throws IOException { //mybatis String resource = "SqlMapConfig.xml"; SqlSession sqlSession = null; try { //通过输入流读取配置文件 InputStream inputStream = Resources.getResourceAsStream(resource); //通过SqlSessionFactoryBuilder,获取SqlSessionFactory SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //通过SqlSessionFactory获取SqlSession sqlSession = sqlSessionFactory.openSession(); //使用session操作数据库 //selectOne第一个参数:指定sql的id(statement id),注意带上namespace;第二个参数:向sql中传的参数值 User user = sqlSession.selectOne("test.findUserById", 100100); System.out.println(user); } catch (Exception e) { e.printStackTrace(); } finally { if (sqlSession != null) { //session 关闭,释放资源 sqlSession.close(); } } } } //添加 public class Mybatis_insert { public static void main(String[] args) throws IOException { //mybatis String resource = "SqlMapConfig.xml"; SqlSession sqlSession = null; try { //通过输入流读取配置文件 InputStream inputStream = Resources.getResourceAsStream(resource); //通过SqlSessionFactoryBuilder,获取SqlSessionFactory SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); //通过SqlSessionFactory获取SqlSession sqlSession = sqlSessionFactory.openSession(); User user = new User(); user.setUsername("Tomas"); user.setSex("1"); user.setBirthday(new Date()); user.setAddress("BeiJing"); user.setDetail("Nice person"); user.setScore(99.1f); //使用session操作数据库 sqlSession.insert("test.insertUser", user); //提交事务 sqlSession.commit(); System.out.println(user); } catch (Exception e) { e.printStackTrace(); } finally { if (sqlSession != null) { //session 关闭,释放资源 sqlSession.close(); } } } }
主键返回:通过修改sql映射文件,可以讲mysql或oracle自增主键返回:
<!-- 用户添加 --> <insert id="insertUser" parameterType="mybatis.model.User"> <!-- keyProperty指定主键映射的pojo对象的属性 order 指selectKey的执行顺序,MySql设置为after, oracle设置为before,因为oracle要先生成Sequence 而在实际使用主键时,MySql使用uuid() 即 SELECT UUID() --> <selectKey keyProperty="userId" order="BEFORE" resultType="java.lang.Integer"> <!-- Mysql: select last_insert_ID() --> <!-- Oracle:必须要先取得Sequence的Nextval,放入pojo中,然后执行insert操作。否则,自增长主键会变成+2,而不是+1 --> select seq_userId.Nextval from dual </selectKey> insert into users (userId, username, birthday, sex, address, detail, score) values (#{userId}, #{username}, #{birthday}, #{sex}, #{address}, #{detail}, #{score}) </insert>
添加<selectKey>实现将主键返回:
keyProperty:返回的主键是pojo中的哪个属性
order:selectKey执行顺序,相对与insert语句来说。Mysql的自增原理执行完insert语句后才将主键生成,所以执行顺序为after;oracle使用序列Sequence,先生成自增主键,应该使用before。
resultType:返回的主键类型
程序步骤总结:
创建 SqlSessionFactory
通过 SqlSessionFactory 创建 SqlSession
通过 SqlSession 执行数据库操作
调用 session.commit() 提交事务
调用 session.close() 关闭会话
三、MyBatis解决jdbc编程的问题:
1、 数据库链接创建、释放频繁造成系统资源浪费从而影响系统性能,如果使用数据库链接池可解决此问题。
解决:在SqlMapConfig.xml中配置数据链接池,使用连接池管理数据库链接。
2、 Sql语句写在代码中造成代码不易维护,实际应用sql变化的可能较大,sql变动需要改变java代码。
解决:将Sql语句配置在mapper.xml文件中与java代码分离。
3、 向sql语句传参数麻烦,因为sql语句的where条件不一定,可能多也可能少,占位符需要和参数一一对应。
解决: Mybatis底层使用Executor执行器自动将java对象映射至sql语句。
4、 对结果集解析麻烦,sql变化导致解析代码变化,且解析前需要遍历,如果能将数据库记录封装成pojo对象解析比较方便。
解决:Mybatis底层使用Executor执行器自动将sql执行结果映射至java对象。
四、MyBatis与Hibernate的不同之处:
Mybatis和hibernate不同,它不完全是一个ORM框架, 因为MyBatis需要程序员自己编写Sql语句,不过mybatis可以通过XML或注解方式灵活配置要运行的sql语句,并将java对象和sql语句映射生成最终执行的sql,最后将sql执行的结果再映射生成java对象。
Mybatis学习门槛低,简单易学,程序员直接编写原生态sql,可严格控制sql执行性能,灵活度高,非常适合对关系数据模型要求不高的软件开发,例如互联网软件、企业运营类软件等,因为这类软件需求变化频繁,一但需求变化要求成果输出迅速。但是灵活的前提是mybatis无法做到数据库无关性,如果需要实现支持多种数据库的软件则需要自定义多套sql映射文件,工作量大。
Hibernate对象/关系映射能力强,数据库无关性好,对于关系模型要求高的软件(例如需求固定的定制化软件)如果用hibernate开发可以节省很多代码,提高效率。但是Hibernate的缺点是学习门槛高,要精通门槛更高,而且怎么设计O/R映射,在性能和对象模型之间如何权衡,以及怎样用好Hibernate需要具有很强的经验和能力才行。
总之,按照用户的需求在有限的资源环境下只要能做出维护性、扩展性良好的软件架构都是好架构,所以框架只有适合才是最好。
五、
SqlSession:封装了对数据库的sql操作,如:查询、插入、更新、删除等。通过 SqlSessionFactory 创建SqlSession,而 SqlSessionFactory 是通过 SqlSessionFactoryBuilder进行创建的。
SqlSessionFactoryBuilder:只用于创建 SqlSessionFactory ,可以当成一个工具类使用,在使用时随时拿来使用,不需要特殊处理为共享对象。
SqlSessionFactory:是一个接口,接口中定义了 openSession 的不同方式,MyBatis 默认使用 DefaultSqlSessionFactory 作为接口实现,SqlSessionFactory 一旦创建后可以重复使用,实际上通常设计为单例模式。
SqlSession:是一个接口,定义了数据库的操作。执行过程如下:
加载数据源等配置信息 Environment environment = configuration.getEnvironment();
创建数据库连接
创建事务对象
创建Executor,SqlSession所有操作都是通过Executor完成,MyBatis源码如下:
if (ExecutorType.BATCH == executorType) { executor = new BatchExecutor(this, transaction); } else if (ExecutorType.REUSE == executorType) { executor = new ReuseExecutor(this, transaction); } else { executor = new SimpleExecutor(this, transaction); } if (cacheEnabled) { executor = new CachingExecutor(executor, autoCommit); }
SqlSession 的实现类 即 DefaultSqlSession,此对象中 操作数据库实质上使用的是Executor
结论:每个线程都应该有自己的 SqlSession 实例。SqlSession 的实例不能共享使用,它是非线程安全的,因此最佳的范围是 请求 或 方法 范围。绝对不能将 SqlSession 实例的引用放在一个类的静态字段甚至是实例字段中。
标签:
原文地址:http://my.oschina.net/u/1757476/blog/499592