spring-data-mongodb

whatsmars-spring-data/pom.xml

@@ -20,6 +20,10 @@
             <groupId>org.springframework.data</groupId>
             <artifactId>spring-data-elasticsearch</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-mongodb</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.hongxi</groupId>

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/Application.java

 package org.hongxi.whatsmars.spring.data;
 
 import org.hongxi.whatsmars.common.profile.ProfileUtils;
-import org.hongxi.whatsmars.spring.data.config.PropertyConfiguration;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 
 public class Application {
 
     public static void main(String[] args) {
         AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
-        context.register(PropertyConfiguration.class);
         context.scan("org.hongxi.whatsmars.spring.data");
         context.getEnvironment().setActiveProfiles(ProfileUtils.getProfile());
         context.refresh();

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/config/EsConfiguration.java → whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/config/ElasticsearchConfiguration.java

@@ -9,7 +9,7 @@ import org.springframework.data.elasticsearch.client.TransportClientFactoryBean;
 import java.util.Properties;
 
 @Configuration
-public class EsConfiguration {
+public class ElasticsearchConfiguration {
 
     @Value("${es.cluster.name}")
     private String clusterName;

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/config/MogoConfiguration.java

+package org.hongxi.whatsmars.spring.data.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.ImportResource;
+
+@Configuration
+@ImportResource("classpath:spring-mongo.xml")
+public class MogoConfiguration {
+}

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/model/Customer.java

+package org.hongxi.whatsmars.spring.data.model;
+
+import org.springframework.data.annotation.Id;
+
+public class Customer {
+
+	@Id
+	private String id;
+
+	private String firstName;
+	private String lastName;
+
+	public Customer() {
+	}
+
+	public Customer(String firstName, String lastName) {
+		this.firstName = firstName;
+		this.lastName = lastName;
+	}
+
+	@Override
+	public String toString() {
+		return String.format("Customer[id=%s, firstName='%s', lastName='%s']", id,
+				firstName, lastName);
+	}
+
+}
\ No newline at end of file

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/repository/CustomerRepository.java

+package org.hongxi.whatsmars.spring.data.repository;
+
+import org.hongxi.whatsmars.spring.data.model.Customer;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+import java.util.List;
+
+public interface CustomerRepository extends MongoRepository<Customer, String> {
+
+	Customer findByFirstName(String firstName);
+
+	List<Customer> findByLastName(String lastName);
+
+}
\ No newline at end of file

whatsmars-spring-data/src/main/java/org/hongxi/whatsmars/spring/data/service/DataService.java

 package org.hongxi.whatsmars.spring.data.service;
 
 import org.elasticsearch.client.transport.TransportClient;
+import org.hongxi.whatsmars.spring.data.repository.CustomerRepository;
+import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
@@ -13,4 +15,8 @@ public class DataService {
     private RedisTemplate<Integer, String> redisTemplate;
     @Resource
     private TransportClient transportClient;
+    @Resource
+    private MongoTemplate mongoTemplate;
+    @Resource
+    private CustomerRepository customerRepository;
 }

whatsmars-spring-data/src/main/resources/application-test.properties

@@ -2,4 +2,8 @@ redis.host=127.0.0.1
 redis.port=6379
 
 es.cluster.name=elasticsearch
-es.cluster.nodes=127.0.0.1:9300
\ No newline at end of file
+es.cluster.nodes=127.0.0.1:9300
+
+mongo.host=127.0.0.1
+mongo.port=27017
+mongo.db=test
\ No newline at end of file

whatsmars-spring-data/src/main/resources/spring-mongo.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:mongo="http://www.springframework.org/schema/data/mongo"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+       http://www.springframework.org/schema/beans/spring-beans.xsd
+       http://www.springframework.org/schema/data/mongo
+       http://www.springframework.org/schema/data/mongo/spring-mongo.xsd">
+
+    <mongo:mongo-client id="mongoClient" host="${mongo.host}" port="${mongo.port}">
+        <mongo:client-options />
+    </mongo:mongo-client>
+
+    <mongo:db-factory dbname="${mongo.db}" mongo-ref="mongoClient" />
+
+    <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
+        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
+    </bean>
+
+    <mongo:repositories base-package="org.hongxi.whatsmars.spring.data.repository" />
+
+</beans>
\ No newline at end of file