1.为什么要用到SQL语句构建器
我们除了必要的动态SQL语句有时还需要在java代码里构建SQL语句,而mybatis它提供了可以让我们把SQL语句中的加号,引号,换行,还要嵌入的AND OR 连接等格式化问题解放出来,当然如果你在SQL语句方面能力比较强,可以忽略这个了.
2.下面我们用实例来演示mybatis的这一功能
(1).我们首先建一个SqlProvider类:
package com.it.test;
import com.it.pojo.User;
import org.apache.ibatis.jdbc.SQL;
public class SqlProvider {
public String getUserAll(){
return new SQL().
SELECT("name","pass","phone")
.FROM("users")
.toString();
}
public String saveUser(){
return new SQL()
.INSERT_INTO("users")
.VALUES("uid","null")
.VALUES("name","'yu2'")
.VALUES("pass","'1234'")
.VALUES("phone","'18855481393'")
.toString();
}
public String saveUsers(User user){
return new SQL()
.INSERT_INTO("users")
.VALUES("uid","null")
.VALUES("name","#{name}")
.VALUES("pass","#{pass}")
.VALUES("phone","#{phone}")
.toString();
}
}
上面是我写的三个方法来进行对sql操作,他们的返回值如果你打印出来的话其实是Sql语句,只不过它用方法的形给封装好了,这样我们就可以避免一样格式化的问题.
这里我们要注意的是saveUser()方法它的VALUES()中的第二参数因为是字符串所以要加上单引号.
而saveUsers(User user)方法中它有一个对象参数,可以像以前一样用#{value}方法注入进去.
(2).写好的关建的SqlProvider类我们可以再创建一个接口(SqlProviderDao)
package com.it.test;
import com.it.pojo.User;
import org.apache.ibatis.annotations.InsertProvider;
import org.apache.ibatis.annotations.SelectProvider;
import java.util.List;
public interface SqlProviderDao {
@SelectProvider(type = SqlProvider.class,method = "getUserAll")
List<User> getUserAll();
@InsertProvider(type = SqlProvider.class,method = "saveUser")
// @Options(useGeneratedKeys = true,keyProperty = "uid")
int saveUser();
@InsertProvider(type = SqlProvider.class,method = "saveUsers")
// @Options(useGeneratedKeys = true,keyProperty = "uid")
int saveUsers(User user);
}
上面的代码我们可以看到是以接口的形式来实现的,所以我们要主意方法是不能重载的.
(3).下面是测试代码
package com.it.test;
import com.it.pojo.User;
import com.it.utils.SessionUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.List;
public class TestProvider {
private SqlSession mSession = null;
@Before
public void setUp(){
mSession = SessionUtils.getSession();
}
@After
public void tearDown(){
SessionUtils.closeSession(mSession);
}
@Test
public void testSqlProvider(){
SqlProvider sp = new SqlProvider();
String sql = sp.getUserAll();
System.out.println(sql);
}
@Test
public void testGetAllUser(){
SqlProviderDao mapper = mSession.getMapper(SqlProviderDao.class);
List<User> users = mapper.getUserAll();
for (User u : users) {
System.out.println(u);
}
}
@Test
public void testSaveUser(){
SqlProviderDao mapper = mSession.getMapper(SqlProviderDao.class);
int result = mapper.saveUser();
System.out.println(result);
}
@Test
public void testSaveUsers(){
User user = new User();
user.setName("wh");
user.setPass("456");
user.setPhone("18855481393");
SqlProviderDao mapper = mSession.getMapper(SqlProviderDao.class);
int result = mapper.saveUsers(user);
System.out.println(result);
}
}
注:mSession我是写了一个可以获得SqlSession的工具类,这里我就不给出来了.
中国加油!武汉加油!千锋加油!自己加油!