mongodb数据库连接测试

generic-parent/pom.xml

@@ -19,6 +19,8 @@
 
     <modules>
 
+        <module>user</module>
+
     </modules>
 
     <properties>
@@ -32,6 +34,11 @@
 
     <dependencies>
 <!--        mongodb-->
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-mongodb</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-mongodb</artifactId>
@@ -74,24 +81,24 @@
         </dependency>
 
         <!--Nacos依赖-->
-        <dependency>
-            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
-            <version>2.2.6.RELEASE</version>
-            <!--openfeign里面有复载均衡，所以这里必须注释掉，不然会冲突-->
-            <exclusions>
-                <exclusion>
-                    <groupId>org.springframework.cloud</groupId>
-                    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-
-        <dependency>
-            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
-            <version>2.2.6.RELEASE</version>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>com.alibaba.cloud</groupId>-->
+<!--            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>-->
+<!--            <version>2.2.6.RELEASE</version>-->
+<!--            &lt;!&ndash;openfeign里面有复载均衡，所以这里必须注释掉，不然会冲突&ndash;&gt;-->
+<!--            <exclusions>-->
+<!--                <exclusion>-->
+<!--                    <groupId>org.springframework.cloud</groupId>-->
+<!--                    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>-->
+<!--                </exclusion>-->
+<!--            </exclusions>-->
+<!--        </dependency>-->
+
+<!--        <dependency>-->
+<!--            <groupId>com.alibaba.cloud</groupId>-->
+<!--            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>-->
+<!--            <version>2.2.6.RELEASE</version>-->
+<!--        </dependency>-->
 
         <!--openfeign依赖 Feign的注解定义接口，调用这个接口，就可以调用服务注册中心的服务-->
         <dependency>
@@ -104,6 +111,15 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-loadbalancer</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.20</version>
+        </dependency>
+
+
+
     </dependencies>
 
     <dependencyManagement>

generic-parent/user/src/main/java/com/example/user/UserApplication.java

@@ -9,5 +9,4 @@ public class UserApplication {
     public static void main(String[] args) {
         SpringApplication.run(UserApplication.class, args);
     }
-
 }

generic-parent/user/src/main/java/com/example/user/controller/UserController.java

@@ -0,0 +1,25 @@
+package com.example.user.controller;
+
+
+import com.example.user.domain.User;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+    @Autowired
+    MongoTemplate mongoTemplate;
+
+    //@PostMapping("/save")
+    public User add(){
+        User user = new User();
+        user.setUsername("zhangyang");
+        System.out.println(mongoTemplate.insert(user));
+        return mongoTemplate.insert(user);
+    }
+}

generic-parent/user/src/main/java/com/example/user/domain/User.java

@@ -0,0 +1,15 @@
+package com.example.user.domain;
+
+import lombok.Data;
+import org.bouncycastle.cms.bc.BcKeyTransRecipientInfoGenerator;
+
+@Data
+public class User {
+
+
+    private String _id;
+
+    private String username;
+
+    private Integer age;
+}

generic-parent/user/src/main/resources/application.yml

@@ -1 +1,5 @@
-
+#数据库配置
+spring:
+  data:
+    mongodb:
+      uri: mongodb://hitsheep:hitsheep@localhost:27717/hitsheep

generic-parent/user/src/test/java/com/example/user/UserApplicationTests.java

@@ -1,13 +1,42 @@
 package com.example.user;
 
+import com.example.user.domain.User;
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringBootConfiguration;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.mongodb.core.MongoTemplate;
+
 
 @SpringBootTest
 class UserApplicationTests {
+    @Autowired
+    MongoTemplate mongoTemplate;
 
     @Test
     void contextLoads() {
+
+        User user = new User();
+        user.setUsername("zhangyang");
+        mongoTemplate.insert( user );
+
+        //Query query = new Query(Criteria.where("username").is("zhangyang") );
+
+        //List<User> users = mongodbTemplate.findAll(User.class);
+
+        //System.out.println( users );
+
+
+        //mongodbTemplate.remove( query, User.class );
+
+        //System.out.println(mongodbTemplate.find(query, User.class));
+
+        //Update update = new Update();
+        //update.set(  "name",  "lisi"  );
+        //mongodbTemplate.upsert( query, update , User.class );
+
+
+
     }
 
 }