麻豆蜜桃传媒在线观看,99草精品视频,在线观看免费亚洲

Spring Data，是為數據訪問提供熟悉且一致的基于Spring的編程模型，同時仍然保留底層數據存儲的特殊特性。

它是對于數據訪問技術，關系數據庫和非關系數據庫，map-reduce框架和基于云的數據服務變得容易。Spring Data是一個總括項目，其中包含很多特定于數據庫相關的子項目。

首先，先帶大家看一下本篇文章的大致介紹。

沒目錄怎么知道這篇到底有多少干貨呢?

Spring Data是什么
Spring Data能干什么
Spring Data的第一個HelloWorld程序
通過名字來確定方法
通過注解的形式來實現查詢
寫本地的SQL查詢
增刪改的玩法
使用框架中提供的增刪改查的方法
分頁和排序
JpaRepository的使用

是不是很清晰呢，現在開始進入正文，一個一個來：

Spring Data是什么

我們傳統的開發中，我們的整個DAO層的代碼上都是相對來說，都是比較復雜的，在這種情況下，Spring團隊就考慮到一個問題，能不能開發一個框架，這個框架能夠最大限度的減少DAO層的開發呢?

Spring Data就是為了簡化DAO層操作的一個框架

傳統的增刪改查在我們的Spring Data中已經實現了，也就是說大部分的DAO層操作部分不用寫了，僅僅只是需要編寫復雜的業務的調用就可以啦

寫的這部分的代碼，是需要寫接口的聲明就可以啦，不用寫實現，這個實現是自動實現的

Spring Data能干什么

主要用途：

傳統的增刪改查
排序
分頁
排序后分頁

即使你需要寫DAO，也只是寫聲明就可以啦，不用寫實現

Spring Data的第一個HelloWorld程序(JPA、Hibernate、Spring、SpringMVC、Spring Data)

導包

編寫配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:jpa="http://www.springframework.org/schema/data/jpa"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/data/jpa
http://www.springframework.org/schema/data/jpa/spring-jpa-1.2.xsd">
<context:property-placeholder location="classpath:config/db.properties"/>
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${driverClass}"></property>
<property name="jdbcUrl" value="${url}"></property>
<property name="user" value="${user}"></property>
<property name="password" value="${password}"></property>
<property name="acquireIncrement" value="${acquireIncrement}"></property>
<property name="maxPoolSize" value="${maxPoolSize}"></property>
<property name="minPoolSize" value="${minPoolSize}"></property>
<property name="maxStatements" value="${maxStatements}"></property>
</bean>
<bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
</bean>
<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
<property name="dataSource" ref="dataSource"></property>
<property name="packagesToScan" value="com.qy.helloworld"></property>
<property name="jpaVendorAdapter" ref="jpaVendorAdapter"></property>
<property name="jpaProperties">
<props>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.format_sql">true</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</prop>
</props>
</property>
</bean>
<bean id="jpaTransactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="dataSource" ref="dataSource"></property>
<property name="entityManagerFactory" ref="entityManagerFactory"></property>
</bean>
<tx:annotation-driven transaction-manager="jpaTransactionManager"/>
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>
<context:component-scan base-package="com.qy.helloworld"></context:component-scan>
<jpa:repositories base-package="com.qy.helloworld" entity-manager-factory-ref="entityManagerFactory" transaction-manager-ref="jpaTransactionManager"></jpa:repositories>
</beans>

編寫實體類和映射

@Entity
@Table(name="t_user")
public class User {
@Id
@GeneratedValue(strategy=GenerationType.IDENTITY)
private int userId;
private String userName;
private String password;
}

編寫Repository類

public interface UserRepository extends Repository<User,Integer>{
/**
* 這個的意思是通過id找用戶
* @Title: getByUserId
* @Description: TODO
* @param: @param userId
* @param: @return
* @return: User
* @throws
*/
public User getByUserId(int userId);
}

測試

ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserRepository userRepository=applicationContext.getBean(UserRepository.class);
User users=userRepository.findByUserId(1);
}

通過名字來確定方法

代碼演示：

舉例如下：

public interface UserRepository extends Repository<User,Integer>{
/**
* 這個的意思是通過id找用戶
* @Title: getByUserId
* @Description: TODO
* @param: @param userId
* @param: @return
* @return: User
* @throws
*/
public User getByUserId(int userId);
/**
* 記住查詢的開頭只能是 get 或者 find 開頭 By:通過什么查詢
* @Title: findByUserId
* @Description: TODO
* @param: @param userId
* @param: @return
* @return: User
* @throws
*/
public User findByUserId(int userId);
/**
* 通過用戶名的模糊查詢
* @Title: findByUserNameLike
* @Description: TODO
* @param: @param userName
* @param: @return
* @return: List<User>
* @throws
*/
public List<User> findByUserNameLike(String userName);
/**
* 通過用戶名和密碼的Like來進行查詢
* @Title: findByUserNameLikeAndPasswordLike
* @Description: TODO
* @param: @param userName
* @param: @return
* @return: List<User>
* @throws
*/
public List<User> findByUserNameLikeAndPasswordLike(String userName,String password);
/**
* 用戶名和密碼like 然后id小于一個范圍
* @Title: findByUserNameLikeAndPasswordLikeAndUserIdLessThan
* @Description: TODO
* @param: @param userName
* @param: @param password
* @param: @param userId
* @param: @return
* @return: List<User>
* @throws
*/
public List<User> findByUserNameLikeAndPasswordLikeAndUserIdLessThan(String userName,String password,int userId);
}

注意：一般情況下不會通過名字直接來寫相應的方法，因為如果條件過多那么這個時候我們就存在名字特別長的問題

通過注解的模式來實現查詢

代碼演示：

舉例如下：

/**
* 查詢所有沒有條件直接查詢
* @Title: findUserAll
* @Description: TODO
* @param: @return
* @return: List<User>
* @throws
*/
@Query("from User")
public List<User> findUserAll();
/**
* 通過id來查找數據參數直接拼接到后面
* @Title: findUserById
* @Description: TODO
* @param: @param userId
* @param: @return
* @return: List<User>
* @throws
*/
@Query("from User u where u.userId<3")
public List<User> findUserById();
/**
* 通過id查詢存在占位符的情況
* @Title: findUserById1
* @Description: TODO
* @param: @param userId
* @param: @return
* @return: List<User>
* @throws
*/
@Query("from User u where u.userId<?")
public List<User> findUserById1(int userId);
/**
* 多條件的查詢可以指定當前的參數映射的這個位置
* @Title: getUserByNameAndId
* @Description: TODO
* @param: @param userName
* @param: @param userId
* @param: @return
* @return: User
* @throws
*/
@Query("from User u where u.userId=?2 and u.userName=?1")
public User getUserByNameAndId(String userName,int userId);
/**
* 模糊查詢的時候動態拼接上 %的問題
* @Title: findUserByLike1
* @Description: TODO
* @param: @param userName
* @param: @return
* @return: List<User>
* @throws
*/
@Query("from User u where u.userName like concat ('%',?,'%')")
public List<User> findUserByLike1(String userName);

寫本地的SQL 查詢

代碼演示：

舉例如下：

/**
* 通過
* @Title: findUserAll11
* @Description: TODO
* @param: @return
* @return: List<User>
* @throws
*/
@Query(nativeQuery=true,value="select * from t_user")
public List<User> findUserAll11();

增刪改的玩法

代碼演示：

添加業務邏輯增加事務環境：

@Service
@Transactional //提供一個事務的環境
public class UserService {
@Autowired
private UserRepository userRepository=null;
/**
* 數據的更新
* @Title: update
* @Description: TODO
* @param: @param userName
* @param: @param password
* @param: @param userId
* @return: void
* @throws
*/
public void update(String userName,String password,int userId){
userRepository.update(userName, password, userId);
}
public void delete(int userId){
userRepository.delete(userId);
}
public void insert(String userName,String password){
userRepository.insert(userName, password);
}
}

編寫repository的對象：

public interface UserRepository extends Repository<User,Integer>{
/**
* 實現增刪改的方法
* @Title: add
* @Description: TODO
* @param: @param userName
* @param: @param password
* @return: void
* @throws
*/
@Modifying //這個注解的作用表示的是更新數據
@Query("update User u set u.userName=?,u.password=? where u.userId=?")
public void update(String userName,String password,int userId);
/**
* 更新數據
* @Title: delete
* @Description: TODO
* @param: @param userId
* @return: void
* @throws
*/
@Modifying //這個注解的作用表示的是更新數據
@Query("delete User u where u.userId=?")
public void delete(int userId);
/**
* 添加數據
* @Title: insert
* @Description: TODO
* @param: @param userName
* @param: @param password
* @return: void
* @throws
*/
@Modifying //這個注解的作用表示的是更新數據
@Query(nativeQuery=true,value="insert into t_user(userName,password) values(?,?)")
public void insert(String userName,String password);
}

測試：

@Test
public void testHelloWorld() throws Exception {
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserService userService=applicationContext.getBean(UserService.class);
userService.insert("小羽","做程序的");

使用框架中提供的增刪改查的方法

代碼演示：

提供的是Repository：

public interface UserRepository extends CrudRepository<User,Integer>{

分頁和排序

代碼演示：

提供的Repository：

public interface UserRepository extends PagingAndSortingRepository<User,Integer>{

測試：

public class Test001 {
@Test
public void testPaging() throws Exception {
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserRepository userRepository=applicationContext.getBean(UserRepository.class);
/**
* 第一個參數:當前的頁的頁數是多少頁數是從0開始的第二頁:2-1
* 第二個參數:表示的是每一頁條目數
*/
Page<User> pages=userRepository.findAll(new PageRequest(2-1,2));
System.out.println("查詢到的數據:"+pages.getContent());
System.out.println("數據的條目數:"+pages.getSize());
System.out.println("頁數:"+pages.getNumber());
System.out.println("數據條目的總數:"+pages.getTotalElements());
System.out.println("一共的頁數:"+pages.getTotalPages());
System.out.println("排序的規則:"+pages.getSort());
}
/**
* 排序
* @Title: testSort
* @Description: TODO
* @param: @throws Exception
* @return: void
* @throws
*/
@Test
public void testSort() throws Exception {
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserRepository userRepository=applicationContext.getBean(UserRepository.class);
/**
* 排序
* 第一個參數：升序或者降序 Direction.ASC/DESC
* 第二個參數: 排序的這個列
*/
List<User> users=(List<User>) userRepository.findAll(new Sort(Direction.DESC,"userId"));
System.out.println(users);
}
/**
* 排序后分頁
* @Title: testSortAndPaging
* @Description: TODO
* @param: @throws Exception
* @return: void
* @throws
*/
@Test
public void testSortAndPaging() throws Exception {
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserRepository userRepository=applicationContext.getBean(UserRepository.class);
Page<User> pages=userRepository.findAll(new PageRequest(2-1,2,new Sort(Direction.DESC,"userId")));
System.out.println(pages.getContent());
}

JpaRepository的使用

代碼演示：

提供的repository：

public interface UserRepository extends JpaRepository<User,Integer>{

測試：

public class Test001 {
@Test
public void testPaging() throws Exception {
ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("config/bean-base.xml");
//獲取DAO的對象
UserRepository userRepository=applicationContext.getBean(UserRepository.class);
// long count=userRepository.count();
// User user=userRepository.findOne(15);
// user.setUserName("小羽");
//保存或者更新數據
// userRepository.saveAndFlush(user);
List<User> users=userRepository.findAll();
//批處理
userRepository.deleteInBatch(users);
//System.out.println("統計:"+count);
}
}