mongodb事务_SpringBoot2快速教程：WebFlux集成Mongodb（四）

docker volume create mongo_data_db
docker volume create mongo_data_configdb

docker run -d --name mongo -v mongo_data_configdb:/data/configdb -v mongo_data_db:/data/db -p 27017:27017 mongo --auth

docker exec -it mongo mongo admin// 容器名 // mongo命令 数据库名# 创建最高权限用户
db.createUser({ user: &＃39;admin&＃39;, pwd: &＃39;admin&＃39;, roles: [ { role: "root", db: "admin" } ] });

docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin

show dbs

use admin

show collections

db.city.find().pretty()

org.springframework.bootspring-boot-starter-data-mongodb-reactive

spring.data.mongodb.host&＃61;localhost
spring.data.mongodb.database&＃61;admin
spring.data.mongodb.port&＃61;27017
spring.data.mongodb.username&＃61;admin
spring.data.mongodb.password&＃61;admin

import org.springframework.data.annotation.Id;/*** 城市实体类**/
public class City {/*** 城市编号*/&＃64;Idprivate Long id;/*** 省份编号*/private Long provinceId;/*** 城市名称*/private String cityName;/*** 描述*/private String description;public Long getId() {return id;}public void setId(Long id) {this.id &＃61; id;}public Long getProvinceId() {return provinceId;}public void setProvinceId(Long provinceId) {this.provinceId &＃61; provinceId;}public String getCityName() {return cityName;}public void setCityName(String cityName) {this.cityName &＃61; cityName;}public String getDescription() {return description;}public void setDescription(String description) {this.description &＃61; description;}
}

import org.spring.springboot.domain.City;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.stereotype.Repository;&＃64;Repository
public interface CityRepository extends ReactiveMongoRepository {}

Mono insert(S var1); Flux insert(Iterable var1); Flux insert(Publisher var1); Flux findAll(Example var1); Flux findAll(Example var1, Sort var2);

Flux findByLastname(String lastname);&＃64;Query("{ &＃39;firstname&＃39;: ?0, &＃39;lastname&＃39;: ?1}")Mono findByFirstnameAndLastname(String firstname, String lastname);// Accept parameter inside a reactive type for deferred executionFlux findByLastname(Mono lastname);Mono findByFirstnameAndLastname(Mono firstname, String lastname);&＃64;Tailable // Use a tailable cursorFlux findWithTailableCursorBy();

&＃64;Component
public class CityHandler {private final CityRepository cityRepository;&＃64;Autowiredpublic CityHandler(CityRepository cityRepository) {this.cityRepository &＃61; cityRepository;}public Mono save(City city) {return cityRepository.save(city);}public Mono findCityById(Long id) {return cityRepository.findById(id);}public Flux findAllCity() {return cityRepository.findAll();}public Mono modifyCity(City city) {return cityRepository.save(city);}public Mono deleteCity(Long id) {cityRepository.deleteById(id);return Mono.create(cityMonoSink -> cityMonoSink.success(id));}
}

&＃64;RestController
&＃64;RequestMapping(value &＃61; "/city")
public class CityWebFluxController {&＃64;Autowiredprivate CityHandler cityHandler;&＃64;GetMapping(value &＃61; "/{id}")public Mono findCityById(&＃64;PathVariable("id") Long id) {return cityHandler.findCityById(id);}&＃64;GetMapping()public Flux findAllCity() {return cityHandler.findAllCity();}&＃64;PostMapping()public Mono saveCity(&＃64;RequestBody City city) {return cityHandler.save(city);}&＃64;PutMapping()public Mono modifyCity(&＃64;RequestBody City city) {return cityHandler.modifyCity(city);}&＃64;DeleteMapping(value &＃61; "/{id}")public Mono deleteCity(&＃64;PathVariable("id") Long id) {return cityHandler.deleteCity(id);}
}

cd springboot-webflux-3-mongodb
mvn clean install

... 省略
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:30 min
[INFO] Finished at: 2017-10-15T10:00:54&＃43;08:00
[INFO] Final Memory: 31M/174M
[INFO] ------------------------------------------------------------------------

... 省略
2018-04-10 08:43:39.932 INFO 2052 --- [ctor-http-nio-1] r.ipc.netty.tcp.BlockingNettyContext : Started HttpServer on /0:0:0:0:0:0:0:0:8080
2018-04-10 08:43:39.935 INFO 2052 --- [ main] o.s.b.web.embedded.netty.NettyWebServer : Netty started on port(s): 8080
2018-04-10 08:43:39.960 INFO 2052 --- [ main] org.spring.springboot.Application : Started Application in 6.547 seconds (JVM running for 9.851)


docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin

show dbs

use admin

show collections

db.city.find().pretty()