springMVC+mongodb整合(morphia)
阿新 • • 發佈：2018-12-24
spring版本4.1.6+morphia版本0.11
web.xml配置
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" version="3.0"> <display-name>Archetype Created Web Application</display-name> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:spring-morphia.xml</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <listener> <listener-class>org.springframework.web.util.IntrospectorCleanupListener</listener-class> </listener> <!-- 當hibernate+spring配合使用的時候，如果設定了lazy=true,那麼在讀取資料的時候，當讀取了父資料後， hibernate會自動關閉session，這樣，當要使用子資料的時候，系統會丟擲lazyinit的錯誤， 這時就需要使用spring提供的 OpenSessionInViewFilter,OpenSessionInViewFilter主要是保持Session狀態 知道request將全部頁面傳送到客戶端，這樣就可以解決延遲載入帶來的問題 --> <filter> <filter-name>openSessionInViewFilter</filter-name> <filter-class>org.springframework.orm.hibernate4.support.OpenSessionInViewFilter</filter-class> <init-param> <param-name>singleSession</param-name> <param-value>true</param-value> </init-param> </filter> <filter-mapping> <filter-name>openSessionInViewFilter</filter-name> <url-pattern>*.do</url-pattern> </filter-mapping> <filter> <filter-name>encodingFilter</filter-name> <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class> <async-supported>true</async-supported> <init-param> <param-name>encoding</param-name> <param-value>UTF-8</param-value> </init-param> <init-param> <param-name>forceEncoding</param-name> <param-value>true</param-value> </init-param> </filter> <filter-mapping> <filter-name>encodingFilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> <servlet> <servlet-name>SpringMVC</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:spring-mvc.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> <async-supported>true</async-supported> </servlet> <servlet-mapping> <servlet-name>SpringMVC</servlet-name> <url-pattern>/</url-pattern> </servlet-mapping> <welcome-file-list> <welcome-file>/index.jsp</welcome-file> </welcome-file-list> </web-app>
log4j.properties 配置
#定義LOG輸出級別 log4j.rootLogger=INFO,Console,File #定義日誌輸出目的地為控制檯 log4j.appender.Console=org.apache.log4j.ConsoleAppender log4j.appender.Console.Target=System.out #可以靈活地指定日誌輸出格式，下面一行是指定具體的格式 log4j.appender.Console.layout = org.apache.log4j.PatternLayout log4j.appender.Console.layout.ConversionPattern=[%c] - %m%n #檔案大小到達指定尺寸的時候產生一個新的檔案 log4j.appender.File = org.apache.log4j.RollingFileAppender #指定輸出目錄 log4j.appender.File.File = logs/ssm.log #定義檔案最大大小 log4j.appender.File.MaxFileSize = 10MB # 輸出所以日誌，如果換成DEBUG表示輸出DEBUG以上級別日誌 log4j.appender.File.Threshold = ALL log4j.appender.File.layout = org.apache.log4j.PatternLayout log4j.appender.File.layout.ConversionPattern =[%p] [%d{yyyy-MM-dd HH\:mm\:ss}][%c]%m%n
spring-mongo.properties
##mongo config
mongo.server.host=localhost
mongo.server.port=27017
mongo.server.connectionsperHost=20
mongo.server.threadsAllowedToBlockForConnectionMultiplier=10
mongo.server.dbName=user
mongo.server.user=root
mongo.server.pwd=root
spring-morphia.xml
<?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:aop="http://www.springframework.org/schema/aop" xmlns:util="http://www.springframework.org/schema/util" xmlns:cache="http://www.springframework.org/schema/cache" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-4.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd"> <!-- ：所有類進行掃描，以完成Bean建立和自動依賴注入的功能 --> <context:component-scan base-package="cn.yc" /> <!-- ：啟動Spring MVC的註解功能，完成請求和註解POJO的對映 --> <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter" /> <!-- 引入配置檔案 --> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="location" value="classpath:spring-jdbc.properties" /> </bean> <!-- <context:property-placeholder location="classpath:spring-mongo.properties" /> --> <!-- 使用工廠建立mongo例項 --> <bean id="mongoClient" class="cn.yc.comm.config.MongoClientFactoryBean"> <!-- 設定伺服器列表，預設為localhost:27017 --> <property name="serverStrings"> <array> <value>127.0.0.1:27017</value> </array> </property> </bean> <!-- 使用工廠建立morphia例項，同時完成類對映操作 --> <bean id="morphia" class="cn.yc.comm.config.MorphiaFactoryBean"> <!-- 指定要掃描的POJO包路徑 --> <property name="mapPackages"> <array> <value>cn.yc.comm.bean</value> </array> </property> <!-- 指定要對映的類 --> <!-- <property name="mapClasses"> <array> <value>me.watchzerg.test.morphia.pojo.Hotel</value> <value>me.watchzerg.test.morphia.pojo.Address</value> </array> </property> --> <!-- 掃描包時是否忽略不可用的類，預設為false --> <!-- <property name="ignoreInvalidClasses" value="false"/> --> </bean> <!-- 使用工廠建立datastore，同時完成index和caps的確認操作 --> <bean id="datastore" class="cn.yc.comm.config.DatastoreFactoryBean"> <property name="morphia" ref="morphia" /> <property name="mongoClient" ref="mongoClient" /> <!-- collection的名稱 --> <property name="dbName" value="${mongo.server.dbName}" /> <!-- 使用者名稱和密碼可以為空 --> <property name="username" value="${mongo.server.user" /> <property name="password" value="${mongo.server.pwd" /> <!-- 是否進行index和caps的確認操作，預設為flase --> <property name="toEnsureIndexes" value="true" /> <property name="toEnsureCaps" value="true" /> </bean> <!-- 全域性配置 --> <bean id="config" class="cn.yicha.config.Config"> </bean> <!-- ===============以下是具體DAO的實現===================== --> <!-- 測試 --> <bean id="hotelDao" class="cn.yc.comm.dao.HotelDao"> <constructor-arg ref="datastore" /> </bean> </beans>
spring-mvc.xml 配置
<?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:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
<!-- 自動掃描該包，使SpringMVC認為包下用了@controller註解的類是控制器 -->
<context:component-scan base-package="cn.yc.comm.action" />
<!--避免IE執行AJAX時，返回JSON出現下載檔案 -->
<bean id="mappingJackson2HttpMessageConverter"
class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
<property name="supportedMediaTypes">
<list>
<value>text/html;charset=UTF-8</value>
<value>text/json;charset=UTF-8</value>
<value>application/json;charset=UTF-8</value>
</list>
</property>
</bean>
<!-- 啟動SpringMVC的註解功能，完成請求和註解POJO的對映 -->
<bean
class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter">
<property name="messageConverters">
<list>
<ref bean="mappingJackson2HttpMessageConverter" /> <!-- JSON轉換器 -->
</list>
</property>
</bean>
<!-- String 字元轉轉碼 json 資料配置 -->
<mvc:annotation-driven>
<mvc:message-converters register-defaults="true">
<bean class="org.springframework.http.converter.StringHttpMessageConverter">
<constructor-arg value="UTF-8" />
</bean>
</mvc:message-converters>
</mvc:annotation-driven>
<!-- 對靜態資原始檔的訪問 方案一 （二選一） -->
<mvc:default-servlet-handler />
<!-- 對靜態資原始檔的訪問 方案二 （二選一） -->
<!-- <mvc:resources mapping="/images/**" location="/images/" cache-period="31556926"/>
<mvc:resources mapping="/js/**" location="/js/" cache-period="31556926"/>
<mvc:resources mapping="/css/**" location="/css/" cache-period="31556926"/> -->
<!-- 定義跳轉的檔案的前後綴 ，檢視模式配置 -->
<bean
class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<!-- 這裡的配置我的理解是自動給後面action的方法return的字串加上字首和字尾，變成一個 可用的url地址 -->
<property name="prefix" value="/" />
<property name="suffix" value=".jsp" />
</bean>
<!-- 配置檔案上傳，如果沒有使用檔案上傳可以不用配置，當然如果不配，那麼配置檔案中也不必引入上傳元件包 -->
<bean id="multipartResolver"
class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
<!-- 預設編碼 -->
<property name="defaultEncoding" value="utf-8" />
<!-- 檔案大小最大值 -->
<property name="maxUploadSize" value="10485760000" />
<!-- 記憶體中的最大值 -->
<property name="maxInMemorySize" value="40960" />
</bean>
</beans>pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>cn.yc</groupId>
<artifactId>mongo</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>spring-mongo</name>
<url>http://maven.apache.org</url>
<!-- 配置檔案 -->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<!-- junit版本 -->
<junit.version>4.11</junit.version>
<spring.version>4.1.6.RELEASE</spring.version>
<!-- mongo.driver版本 -->
<mongo.version>2.12.5</mongo.version>
<!-- mongodb框架版本 -->
<morphia.version>0.110</morphia.version>
<!-- dom4j版本 -->
<dom4j.version>1.6.1</dom4j.version>
<!-- jsp版本 -->
<jsp.version>2.0</jsp.version>
<!-- servlet版本 -->
<servlet.version>3.1.0</servlet.version>
<!-- slf4j版本 -->
<slf4j.version>1.7.5</slf4j.version>
<!-- log4j版本 -->
<log4j.version>1.2.17</log4j.version>
<!-- freemarker版本 -->
<freemarker.version>2.3.20</freemarker.version>
<!-- jackson版本 -->
<jackson.version>2.5.1</jackson.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
<scope>test</scope>
</dependency>
<!-- apache-commons start -->
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.10</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-exec</artifactId>
<version>1.3</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.4</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.3.2</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.3.6</version>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>2.3</version>
</dependency>
<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
<version>1.9.2</version>
</dependency>
<!-- apache-commons end -->
<!-- spring依賴開始 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-expression</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-oxm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc-portlet</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-instrument</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-messaging</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-instrument-tomcat</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-websocket</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- spring依賴結束 -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>1.6.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>${mongo.version}</version>
</dependency>
<dependency>
<groupId>org.mongodb.morphia</groupId>
<artifactId>morphia</artifactId>
<version>${morphia.version}</version>
</dependency>
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>${dom4j.version}</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jsp-api</artifactId>
<version>${jsp.version}</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>${servlet.version}</version>
</dependency>
<!-- lsf4j,log4j依賴開始 -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<!-- lsf4j,log4j依賴結束 -->
<!-- freemarker依賴開始 -->
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>${freemarker.version}</version>
</dependency>
<!-- freemarker依賴結束 -->
<!-- jackson依賴開始 -->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-annotations</artifactId>
<version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
<version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-xml</artifactId>
<version>${jackson.version}</version>
</dependency>
<!-- jackson依賴結束 -->
</dependencies>
<build>
<finalName>mongo</finalName>
</build>
</project>
MongoClient 工廠類
public class MongoClientFactoryBean extends AbstractFactoryBean<Mongo>{
// 表示伺服器列表(主從複製或者分片)的字串陣列
private String[] serverStrings;
// mongoDB配置物件 使用預設配置
private MongoClientOptions mongoClientOptions=new MongoClientOptions.Builder().build();
@Override
public Class<?> getObjectType() {
return Mongo.class;
}
public String[] getServerStrings() {
return serverStrings;
}
public void setServerStrings(String[] serverStrings) {
this.serverStrings = serverStrings;
}
@Override
protected MongoClient createInstance() throws Exception {
MongoClient mongoClient =null;
if (null!=mongoClientOptions) {
mongoClient = new MongoClient(getServerList(), mongoClientOptions);
}else {
mongoClient = new MongoClient(getServerList());
}
return mongoClient;
}
/**
* 根據伺服器字串列表，解析出伺服器物件列表
* @Title: getServerList
*
* @return
* @throws Exception
*/
private List<ServerAddress> getServerList() throws Exception {
List<ServerAddress> serverList = new ArrayList<ServerAddress>();
try {
for (String serverString : serverStrings) {
String[] temp = serverString.split(":");
String host = temp[0];
if (temp.length > 2) {
throw new IllegalArgumentException(
"Invalid server address string: " + serverString);
}
if (temp.length == 2) {
serverList.add(new ServerAddress(host, Integer
.parseInt(temp[1])));
} else {
serverList.add(new ServerAddress(host));
}
}
return serverList;
} catch (Exception e) {
throw new Exception(
"Error while converting serverString to ServerAddressList",
e);
}
}
}
MorphiaFactoryBean 返回 morphia例項
public class MorphiaFactoryBean extends AbstractFactoryBean<Morphia>{
/**
* 3 * 要掃描並對映的包 4
*/
private String[] mapPackages;
/**
* 要對映的類
*/
private String[] mapClasses;
/**
* 掃描包時，是否忽略不對映的類 這裡按照Morphia的原始定義，預設設為false
*/
private boolean ignoreInvalidClasses;
@Override
protected Morphia createInstance() throws Exception {
Morphia m = new Morphia();
if (mapPackages != null) {
for (String packageName : mapPackages) {
m.mapPackage(packageName, ignoreInvalidClasses);
}
}
if (mapClasses != null) {
for (String entityClass : mapClasses) {
m.map(Class.forName(entityClass));
}
}
return m;
}
public String[] getMapPackages() {
return mapPackages;
}
public void setMapPackages(String[] mapPackages) {
this.mapPackages = mapPackages;
}
public String[] getMapClasses() {
return mapClasses;
}
public void setMapClasses(String[] mapClasses) {
this.mapClasses = mapClasses;
}
public boolean isIgnoreInvalidClasses() {
return ignoreInvalidClasses;
}
public void setIgnoreInvalidClasses(boolean ignoreInvalidClasses) {
this.ignoreInvalidClasses = ignoreInvalidClasses;
}
@Override
public Class<?> getObjectType() {
return Morphia.class;
}
}
DatastoreFactoryBean
public class DatastoreFactoryBean extends AbstractFactoryBean<Datastore> {
private Morphia morphia; // morphia例項，最好是單例
private MongoClient mongoClient; // mongoClient例項，最好是單例
private String dbName; // 資料庫名
private String username; // 使用者名稱，可為空
private String password; // 密碼，可為空
private boolean toEnsureIndexes = false; // 是否確認索引存在，預設false
private boolean toEnsureCaps = false; // 是否確認caps存在，預設false
@Override
protected Datastore createInstance() throws Exception {
DB db = mongoClient.getDB(dbName);
/* if (db.isAuthenticated()) {
db.authenticate(username, password.toCharArray());
}*/
Datastore ds = morphia.createDatastore(mongoClient, dbName);
if(toEnsureIndexes){
ds.ensureIndexes();
}
if(toEnsureCaps){
ds.ensureCaps();
}
return ds;
}
public Morphia getMorphia() {
return morphia;
}
public void setMorphia(Morphia morphia) {
this.morphia = morphia;
}
public MongoClient getMongoClient() {
return mongoClient;
}
public void setMongoClient(MongoClient mongoClient) {
this.mongoClient = mongoClient;
}
public String getDbName() {
return dbName;
}
public void setDbName(String dbName) {
this.dbName = dbName;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public boolean isToEnsureIndexes() {
return toEnsureIndexes;
}
public void setToEnsureIndexes(boolean toEnsureIndexes) {
this.toEnsureIndexes = toEnsureIndexes;
}
public boolean isToEnsureCaps() {
return toEnsureCaps;
}
public void setToEnsureCaps(boolean toEnsureCaps) {
this.toEnsureCaps = toEnsureCaps;
}
@Override
public Class<?> getObjectType() {
return Datastore.class;
}
@Override
public void afterPropertiesSet() throws Exception {
super.afterPropertiesSet();
if (mongoClient == null) {
throw new IllegalStateException("mongoClient is not set");
}
if (morphia == null) {
throw new IllegalStateException("morphia is not set");
}
}
}
簡單測試
po物件
@Entity(value="hotel",noClassnameStored=true)
@Indexes( @Index("name, stars") )
public class Hotel {
@Id
@JsonIgnore
private ObjectId id;
private String name;
private int stars;
@Embedded
private Address address;
public ObjectId getId() {
return id;
}
public void setId(ObjectId id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getStars() {
return stars;
}
public void setStars(int stars) {
this.stars = stars;
}
public Address getAddress() {
return address;
}
public void setAddress(Address address) {
this.address = address;
}
}@Embedded
public class Address {
private String street;
private String city;
private String postCode;
private String country;
public String getStreet() {
return street;
}
public void setStreet(String street) {
this.street = street;
}
public String getCity() {
return city;
}
public void setCity(String city) {
this.city = city;
}
public String getPostCode() {
return postCode;
}
public void setPostCode(String postCode) {
this.postCode = postCode;
}
public String getCountry() {
return country;
}
public void setCountry(String country) {
this.country = country;
}
}dao層 在xml重配置注入Datastore
public class HotelDao extends BasicDAO<Hotel, ObjectId> {
protected HotelDao(Datastore ds) {
super(ds);
}
}service層
@Service
public class HotelService {
@Autowired
private HotelDao hotelDao;
public int save(Hotel hotel) {
Key<Hotel> key = hotelDao.save(hotel);
if (null != key) {
return 1;
}
return 0;
}
public List<Hotel> getHotels() {
Query<Hotel> query = this.hotelDao.createQuery().filter("address.city", "北京");
List<Hotel> hotels = this.hotelDao.find(query).asList();
return hotels;
}
}controller
@Controller
@RequestMapping("/hotel")
@Scope("prototype")
public class HotelAction {
@Autowired
private HotelService hotelService;
@RequestMapping(value = "/save", method = RequestMethod.POST)
@ResponseBody
public Map<String, Object> save(Hotel hotel) {
Map<String, Object> result = new HashMap<String, Object>();
int save = hotelService.save(hotel);
result.put("status", save);
return result;
}
@RequestMapping(value = "/getHotels", method = RequestMethod.GET)
@ResponseBody
public List<Hotel> getHotels() {
Map<String, Object> result = new HashMap<String, Object>();
List<Hotel> hotels = hotelService.getHotels();
result.put("data", hotels);
return hotels;
}
}