SpringData

Spring Data概述

• SpringDate:Spring的一個子項目.用於簡化數據庫訪問,支持NoSQL和關係型數據庫.其主要目標是使數據庫的訪問變得方便快捷.
• SpringDate項目支持NoSQL存儲:
  • MongoDB(文檔數據庫)
  • Neo4j(圖形數據庫)
  • Redis(鍵/值數據庫)
  • Hbase(列族數據庫)
• SpringDate項目支持的關係型存儲技術:
  • JDBC
  • JPA

JPA Spring Data概述

• JPA Spring Data:致力於減小數據訪問層(DAO)的開發量.開發者惟一要作的,就只是聲明持久層的接口,其餘都交給Spring Data JPA來作.
• 框架是怎麼代替開發者實現業務邏輯的?好比:當有一個UserDao.findUserById()這樣一個方法聲明,大體應該能判斷出這事根據定條件ID查詢出知足條件的User對象.Spring Data JPA作的即是規範方法的名字,根據符合規範的名字來肯定方法須要實現聲明樣的邏輯

使用Spring Data JPA進行持久層開發的四個步驟:

• 配置Spring整合JPA
• 在Spring配置文件中配置SpringData,讓Spring爲聲明的接口建立代理對象.配置了jpa:repositories後,Spring初始化容器時將會掃描base-package指定的包目錄及子目錄,爲繼承Repository或其子接口的接口建立代理對象,並將代理對象註冊爲SpringBean,業務層即可以經過Spring自動封裝的特性來直接使用該對象.
• 聲明持久層的接口,該接口繼承Repository,Repository是一個標記型接口,它不包含任何方法,如必要,Spring Data可實現Repository其餘子接口,其中定義了一些經常使用的增刪改查,以及分頁相關的方法.
• 在接口中聲明須要的方法.Spring Data將根據給定的策略來爲其生成實現代碼

環境搭建

• 1.引入相應jar包
• 2.建立springdata的配置文件

<?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:context="http://www.springframework.org/schema/context"
	xmlns:tx="http://www.springframework.org/schema/tx"
	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-4.0.xsd http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
	<!-- 1.配置數據源 -->
	<context:property-placeholder location="classpath:db.properties"/>
	
	<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
		<property name="user" value="${jdbc.user}"></property>
		<property name="password" value="${jdbc.password}"></property>	
		<property name="driverClass" value="${jdbc.driverClass}"></property>
		<property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
	</bean>
	
	<!-- 2.配置JPA的EntityMangerFactory -->
	<bean id="entityManagerFactory" 
		class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
		<property name="dataSource" ref="dataSource"></property>
		<property name="jpaVendorAdapter">
			<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"></bean>
		</property>
		<!--指定包掃描-->
		<property name="packagesToScan" value="com.springdata.test"></property>
		<property name="jpaProperties">
			<props>
				<!-- 二級緩存相關 -->
				<!--  
				<prop key="hibernate.cache.region.factory_class">org.hibernate.cache.ehcache.EhCacheRegionFactory</prop>
				<prop key="net.sf.ehcache.configurationResourceName">ehcache-hibernate.xml</prop>
				-->
				<!-- 生成的數據表的列的映射策略 -->
				<prop key="hibernate.ejb.naming_strategy">org.hibernate.cfg.ImprovedNamingStrategy</prop>
				<!-- hibernate 基本屬性 -->
				<prop key="hibernate.dialect">org.hibernate.dialect.MySQL5InnoDBDialect</prop>
				<prop key="hibernate.show_sql">true</prop>
				<prop key="hibernate.format_sql">true</prop>
				<prop key="hibernate.hbm2ddl.auto">update</prop>
			</props>
		</property>
	</bean>
	
	<!-- 3.配置事務管理器 -->
	<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
		<property name="entityManagerFactory" ref="entityManagerFactory"></property>
	</bean>
	
	<!-- 4.配置支持註解的事務 -->
	<tx:annotation-driven transaction-manager="transactionManager"/>	
	<!-- 5.配置SpringData -->
	<!-- 加入 jpa 的命名空間 -->
	<!-- base-package:掃描Repository Bean 所在的 package -->
	 <jpa:repositories base-package="com.springdata.test"
	 	entity-manager-factory-ref="entityManagerFactory"></jpa:repositories>

</beans>
複製代碼

• 3.數據庫裏對外鏈接

jdbc.user=root
jdbc.password=root
jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.jdbcUrl=jdbc:mysql://localhost:3306/jpa
複製代碼

• 4.新建junit測試類,測試是否成功鏈接數據庫

class SpringDataTest {

	private ApplicationContext  ctx = null;
	
	{
		ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
	}
	
	@Test
	void testDataSource() throws SQLException {
		DataSource dataSource = ctx.getBean(DataSource.class);
		System.out.println(dataSource.getConnection());
	}

}
複製代碼

鏈接成功打印出鏈接信息

測試JPA

用JPA的EntityMangerFactory代碼生成表

• 1.新建一個實體類,定義屬性,生成get/set,toString方法
  • 在實力類上加註解@Etity和@Table(name="JPA_PERSONS") //意思是在數據庫中建表,name就是表名
  • 在屬性id上面加上@GeneratedValue和@Id註解

@Entity
@Table(name="JPA_PERSONS")
public class Person {

	private Integer id;
	private String lastName;

	private String email;
	private Date birth;

	@GeneratedValue
	@Id
	public Integer getId() {
		return id;
	}

	public void setId(Integer id) {
		this.id = id;
	}
	只截取了一部分
複製代碼

• 2.在測試類中生成數據庫表(裏面不用寫任何代碼)
  • 測試類啓動就會建立ApplicationContext對象,而後會生成上面配置文件的entityManagerFactory,經過entityManagerFactory生成數據庫表(springdata配置文件的第二條)

@Test
	public void testJpa() {
		
	}
複製代碼

啓動無報錯後就會在數據庫中生成一個表(數據是後加的)

SpringData-Repository接口

• 1.在數據庫添加一條測試數據
• 2.新建一個持久層映射類(繼承Repository接口,也可使用註解)
  • @RepositoryDefinition註解要聲明domainClass和idClass屬性
  • 類中寫查詢方法

/**
 * 1.Repository是一個空接口,便是一個標記接口
 * 2.若咱們定義的接口繼承了Repository,則該接口會被IOC容器識別爲一個Repository Bean.
 * 歸入到IOC容器中,進而能夠在該接口中定義知足必定規範的方法.
 * 3.實際上,也能夠經過@RepositoryDefinition 註解來替代繼承Repository 接口
 *
 */
//傳入的兩個泛型:1.要處理的實體類的類型2.主鍵的類型
@RepositoryDefinition(domainClass=Person.class,idClass=Integer.class)
public interface PersonRepsotory{

	//根據lastName 來獲取對應的Person
	Person getByLastName(String lastName);
}
複製代碼

• 3.在測試類中進行測試
  • 經過上下文獲得持久層對象,在經過持久層調用查詢方法查出表中數據
  • 參數是根據別名查詢,因此參數是數據庫中數據"tom"

@Test
	public void testGet() {
		PersonRepsotory personRepsotory = ctx.getBean(PersonRepsotory.class);
		Person person = personRepsotory.getByLastName("tom");
		System.out.println(person);
	}
複製代碼

查詢結果

條件查詢

• 在持久層類中寫查詢方法

//WHERE lastName LIKE ?% AND id < ?(以一個模糊作開始和id小於的條件作查詢)
List<Person> getByLastNameStartingWithAndIdLessThan(String lastName,Integer id);
	
//WHERE lastName LIKE %? AND id < ?(以一個模糊作結束和id小於的條件作查詢)
List<Person> getByLastNameEndingWithAndIdLessThan(String lastName,Integer id);
複製代碼

測試類調用

/*
	 * 條件查詢的方法:以某字符開頭而且id小於?的方法
	 */
	@Test
	public void testKeyWords() {
		List<Person> person = personRepsotory.getByLastNameStartingWithAndIdLessThan("c", 6);
		System.out.println(person);
		
		//(以一個模糊作結束和id小於的條件作查詢)方法
		List<Person> person1 = personRepsotory.getByLastNameEndingWithAndIdLessThan("c", 6);
		System.out.println(person1);
	}
	
複製代碼

@Query註解

• 一些根據關鍵字沒法實現的查詢能夠經過@Query註解來實現

//查詢id值最大的那個Person對象
//使用@Query 註解能夠自定義 JPQL 語句以實現靈活的查詢
@Query("SELECT p FROM Person p WHERE p.id = (SELECT max(p2.id) FROM Person p2)")
Person getMaxIdPerson();
複製代碼

• 傳遞參數的兩種方式

// 爲@Query 註解傳遞參數的方式1:使用佔位符.這種方式參數順序必須一致
@Query("SELECT p FROM Person p WHERE p.lastName = ? AND p.email = ?")
List<Person> testQueryAnnotationParms1(String lastName, String email);

// @Query註解傳遞參數方式2:命名參數的方式,對參數名字進行綁定,能夠不按順序
@Query("SELECT p FROM Person p WHERE p.lastName = :lastName AND p.email = :email")
List<Person> testQueryAnnotationParms2(@Param("email") String email, @Param("lastName") String lastName);
複製代碼