使用Mapper代理方法:
1.定义与SQL映射文件同名的Mapper接口,并将Mapper接口和映射文件(xml文件)放在同一目录下, (一般将xml文件放在resources处,这里的要新建的是dictotry,而且命名时是用/代替. ;如果用.的话不会有分层,会认为包名就是如此比如com.wjy.mapper,用com/wjy/mapper会分层,但是显示的时候仍然是com.wjy.mapper)
2.设置sql映射文件的namespace属性为Mapper接口全限定名
3.在Mapper接口中定义方法,方法名就是sql映射文件中sql语句的id,并保持参数和返回值类型一致。
4.编码 1.通过SqlSession的getMapper方法获取Mapper接口的代理对象2.调用相应的方法完成sql的执行。
记得将主配置文件中的路径改了
举例:增删改查
1.创建项目
2.创建实体类
3.创建UserDao接口(UserDao和UserMapper作用是一样的)
package com.qcby.dao;
import com.qcby.entity.User;
import java.util.List;
public interface UserDao {
/**
* 查询所有用户
*/
public List findAll();
/**
* 通过id查询一条数据
* @param id
* @return
*/
public User findById(int id);
/**
* 增加数据
* @param user
* @return
*/
public int insert(User user);
/**
* 更新数据
* @param user
*/
public int update(User user);
/**
* 删除数据
* @param user
*/
public int delete(int id);
}
4.编写UserDao.xml的配置文件代码
/*查询ID
keyProperty:封装数据到属性
order:数据添加后的 *** 作
resulType:数据类型
*/
select last_insert_id();
insert into user(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address})
update user set username = #{username},birthday = #{birthday},sex = #{sex},address = #{address} where id = #{id}
delete from user where id = #{id}
5. UserTest的代码
注意:修改数据(包括添加、删除、修改数据),如果数据库事务管理,使用JDBC本地策略,则需要手动提交事务,否则,数据库中数据无法修改
package com.qcby.test;
import com.qcby.dao.UserDao;
import com.qcby.entity.User;
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 org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
public class UserTest {
private InputStream in = null;
private SqlSession session = null;
private UserDao mapper = null;
@Before
public void init() throws IOException {
//加载主配置文件,目的是为了构建SqlSessionFactory对象
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//创建SqlSessionFactory对象
SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
//通过SqlSessionFactory工厂对象创建SqlSesssion对象
session = factory.openSession();
//通过Session创建UserDao接口代理对象
mapper = session.getMapper(UserDao.class);
}
@After
public void destory() throws IOException {
//释放资源
session.close();
in.close();
}
/**
* 测试查询所有的方法
*/
@Test
public void run() throws IOException {
/* //加载主配置文件,目的是为了构建SqlSessionFactory对象
InputStream in = Resources.getResourceAsStream("SqlMapConfig.xml");
//创建SqlSessionFactory对象
SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
//通过SqlSessionFactory工厂对象创建SqlSesssion对象
SqlSession session = factory.openSession();
//调用查询所有的方法
List list = session.selectList("com.qcby.dao.UserDao.findAll");
//遍历集合
for (User user : list) {
System.out.println(user);
}
//释放资源
session.close();
in.close();*/
}
/**
* 测试查询所有的方法
*/
@Test
public void testFindAll() {
//调用查询所有的方法
List list = mapper.findAll();
for (User user : list) {
System.out.println(user);
}
}
/**
* 测试
*/
@Test
public void testFindById() throws IOException {
//调用查询ID的方法
User user = mapper.findById(2);
System.out.println(user);
}
/**
* 测试增加
*/
@Test
public void testInsert() throws IOException {
//创建user对象
User user = new User();
user.setUsername("guos");
user.setSex("男");
user.setBirthday(new Date());
user.setAddress("背景");
//调用添加方法
int result = mapper.insert(user);
session.commit();
System.out.println(user.getId());
System.out.println(result);
}
/**
* 测试更新
*/
@Test
public void testUpdate() throws IOException {
//创建user对象
User user = new User();
user.setId(4);
user.setUsername("小花");
user.setSex("女");
user.setBirthday(new Date());
user.setAddress("北京");
//调用更新
int result = mapper.update(user);
session.commit();
System.out.println(result);
}
/**
* 测试删除
*/
@Test
public void testDelete() {
//调用删除
int result = mapper.delete(7);
session.commit();
System.out.println(result);
}
/**
* 测试模糊查询
*/
@Test
public void testfindByUserName(){
//调用查询数量
List list = mapper.findByUserName("%熊%");
session.commit();
for (User user : list) {
System.out.println(user);
}
}
/**
* 测试数量
*/
@Test
public void testfindCount(){
//调用查询数量
int count = mapper.findCount();
session.commit();
System.out.println(count);
}
}
模糊查询符号使用的区别${},#{}
#{} 参数是采用预编译 防止sql注入 这个在sql语句中就写的是?
${}参数是采用sql拼接 无法防止sql注入
#{} 参数是简单类型 (基础类型和字符串),变量可以任意
${} 参数是简单类型 (基础类型和字符串),变量必须是value
#{} 参数是引用类型,变量是引用类型中的属性,不可任意
${} 参数是引用类型 ,变量是引用类型中的属性,不可任意
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)