一 spring jdbc是通过JdbcTemplate这个类来实现增删改查操作。
1.下面是一个例子的核心代码块 首先是核心代码块applicationContext.xml的配置,用来链接数据库
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!--数据库驱动-->
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<!--连接数据库的Url-->
<property name="url" value="jdbc:mysql://localhost:3306/db_spring"/>
<!--连接数据库的用户名密码-->
<property name="username" value="root"/>
<property name="password" value=""/>
</bean>
<!--配置jdbc模板-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--默认必须使用数据源-->
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 事务管理器,依赖于数据源 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 注册事务管理器驱动 -->
<tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
<context:component-scan base-package="com.ssm.jdbc"/>
2.然后是jdbcTemplateTest类来创建表
```java
public class JdbcTemplateTest {
public static void main(String[] args) {
ApplicationContext applicationContext=new ClassPathXmlApplicationContext("resources/applicationContext.xml");
JdbcTemplate jdbcTemplate= (JdbcTemplate) applicationContext.getBean("jdbcTemplate");
jdbcTemplate.execute("create table user("+"id int primary key auto_increment,"+"username varchar(10),"+"password varchar(10))");
}
3.创建user实例类(主要包括一些基本属性和getter setter 方法),UserDao接口来创建业务功能,UserDaoImp来具体实现各种业务功能
public class User {
private Integer id;
private String username;
private String password;
private Integer jf;
public Integer getJf() {
return jf;
}
public void setJf(Integer jf) {
this.jf = jf;
}
public Integer getId() {
return id;
}
public String getUsername() {
return username;
}
public String getPassword() {
return password;
}
public void setId(Integer id) {
this.id = id;
}
public void setUsername(String username) {
this.username = username;
}
public void setPassword(String password) {
this.password = password;
}
@Override
public String toString(){
return "User [id="+ id +",username="+username+",password="+password+"]";
}
}
public interface UserDao {
public int addUser(User user);
public int updateUser(User user);
public int deleteUser(int id);
public List<User> queryUser();
public void transfer(String outUser,String inUser,Integer jf);
}
@Repository("userdao")
public class UserDaoImp implements UserDao {
@Resource(name = "jdbcTemplate")
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate){
this.jdbcTemplate=jdbcTemplate;
}
@Override
public int addUser(User user){
String sql="insert into user(username,password) value(?,?)";
Object[] objects=new Object[]{
user.getUsername(),
user.getPassword()
} ;
int num=this.jdbcTemplate.update(sql,objects);
return num;
}
@Override
public int updateUser(User user){
String sql="update user set username=?,password=? where id=?";
Object[] objects=new Object[]{
user.getUsername(),
user.getPassword(),
user.getId()
};
int num=this.jdbcTemplate.update(sql,objects);
return num;
}
@Override
public int deleteUser(int id){
String sql="delete from user where id=?";
int num=this.jdbcTemplate.update(sql,id);
return num;
}
@Override
public List<User> queryUser() {
String sql="select * from user";
RowMapper<User> rowMapper=new BeanPropertyRowMapper<User>(User.class);
return this.jdbcTemplate.query(sql,rowMapper);
}
@Override
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT,readOnly = false)
public void transfer(String outUser, String inUser, Integer jf) {
this.jdbcTemplate.update("update user set jf=jf+? where username=?",jf,inUser);
int i=1/0;
this.jdbcTemplate.update("update user set jf=jf-? where username=?",jf,outUser);
}
}
4.具体就不一一展示了,下面看一下其中一个测试方法
@Test
public void queryUserTest (){
ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
System.out.println("applicationContext = " + applicationContext);
UserDao userDao= (UserDao) applicationContext.getBean("userdao");
System.out.println("userDao = " + userDao);
List<User> users = userDao.queryUser();
for (User user:users) {
System.out.println("user = " + user);
}
}
5.结果如下
二 mybatis是一个支持普通sql查询存储过程的持久层框架,有了mybatis,应用程序将不再访问底层数据库,以面向对象的方式来操作持久层对象。 它不需要专门创建一个类来实现业务的具体操作,配置也比spring jdbc简单了许多,只需要在映射文件中配置一些基本sql语句实现业务,而且代码量少,如下
<!-- 根据用户编号获取单个信息-->
<select id="findUserById" parameterType="Integer" resultType="com.ssm.mb.User">
select * from t_user where id=#{id}
</select>
<!-- 根据用户编号获取所有信息-->
<select id="findUser" parameterType="Integer" resultType="com.ssm.mb.User">
select * from t_user
</select>
<!-- 查找名字中含有value的所有用户-->
<select id="findUserByName" parameterType="String" resultType="com.ssm.mb.User">
select * from t_user where username like '%${value}%'
</select>
<!-- 添加用户 -->
<insert id="addUser" parameterType="com.ssm.mb.User">
insert into t_user(username,jobs,phone) value(#{username},#{jobs},#{phone})
</insert>
<!-- 更新用户 -->
<update id="updateUser" parameterType="com.ssm.mb.User">
update t_user set username=#{username},jobs=#{jobs},phone=#{phone} where id=#{id}
</update>
<!-- 删除用户-->
<delete id="deleteUser" parameterType="Integer">
delete from t_user where id=#{id}
</delete>
</mapper>
它的核心文件配置主要是配置数据库,数据源等
<configuration>
<!-- 1.配置环境,默认的环境id为mysql-->
<environments default="mysql">
<!-- 1.1配置id为mysql的数据库环境-->
<environment id="mysql">
<!-- 使用jdbc事务管理-->
<transactionManager type="JDBC"></transactionManager>
<!-- 数据库连接池-->
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/db_mybits"/>
<property name="username" value="root"/>
<property name="password" value=""/>
</dataSource>
</environment>
</environments>
<!--配置mapper位置-->
<mappers>
<mapper resource="com/ssm/mapper/UserMapper.xml"/>
</mappers>
</configuration>
1.下面看一下其中一个业务的实现,不要专门创建一个业务实现类,只需要借助 SqlSessionFactory实例来创建sqlsession实例。
@Test
public void findUserTest() throws Exception{
String resource="mybatis-config.xml";
InputStream inputStream= Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
SqlSession sqlSession=sqlSessionFactory.openSession();
List<User> users=sqlSession.selectList("com.ssm.mapper.UserMapper.findUser");
System.out.println(users.toString());
sqlSession.close();
}
2.结果如下
三 总结
所以Mybatis映射文件相当于jdbc上面的实现类。映射文件只需要几行来创建业务,而实现类需要大量的代码来实现几个简单的业务,这大大增加了开发者的工作量,降低了效率。 所以综合来看,mybatis是我们在开发过程中常用到的工具,它比基本的jdbc更加方便简练,不容易出错,大大提升了开发的效率。
|