• Faunadb

    Faunadb和google spanner都属于云分布式数据库天然支持分片(无需做分表分库操作，一库搞定，当然价格另说)，国内的也有比如TiDB  Oceanbase等

    本文使用java语言，其他语言可以跳过；有想直接使用的可以参考(无法访问外网，可以搞个vpn吧!!!，有时会遇到网络问题)：GitHub - fauna/faunadb-jvm: Scala and Java driver for FaunaDB v4

    此文旨在想了解的小伙伴看看（免费使用30天）

    本文演示使用的jdk版本为jdk21

    目录

    1.登录账号

    2.了解一下FQL

    3. 创建数据库，创建集合

    4.点击搜索框中的dashbord进入到控制台然后到控制台创建集合

    5. 生成数据库秘钥

    6.springboot整合项目

    7.实体

    8.service及接口

    9.属性文件配置属性

    10.controller

    11.启动后postman试试

    1.登录账号

    使用github账号或者注册一个

    Welcome to Fauna docs - Fauna Documentation

    2.了解一下FQL

    建议按照图看下去

    3. 创建数据库，创建集合

    最好是跟着官网文档走

    4.点击搜索框中的dashbord进入到控制台然后到控制台创建集合

    （参考：使用 Spring Boot 使用 Fauna 和 Java 开始构建_rxjava_云O生-云原生）

    最新的不一样，使用下面语法

    Collection.create({
      name: 'todos'
    })

    5. 生成数据库秘钥

    记住不要到account哪里去申请

    6.springboot整合项目

    依赖


    com.faunadb
    faunadb-java
    4.4.0
    compile

    实体\service\controller均参考博文：使用 Spring Boot 使用 Fauna 和 Java 开始构建_rxjava_云O生-云原生

    7.实体

    参考这个也行：GitHub - fauna/faunadb-jvm: Scala and Java driver for FaunaDB v4

    1. import lombok.Data;
    2.  
    3. @Data
    4. public abstract class Entity {
    5.     protected  String id;
    6. }
    1. import java.util.List;
    2. import java.util.Optional;
    3.  
    4. public class Page  {
    5.  
    6.     private List data;
    7.     private Optional before;
    8.     private Optional after;
    9.  
    10.  
    11.     public Page(List data, Optional before, Optional after) {
    12.         this.data = data;
    13.         this.before = before;
    14.         this.after = after;
    15.     }
    16.  
    17.     public List getData() {
    18.         return data;
    19.     }
    20.  
    21.     public void setData(List data) {
    22.         this.data = data;
    23.     }
    24.  
    25.     public Optional getBefore() {
    26.         return before;
    27.     }
    28.  
    29.     public void setBefore(Optional before) {
    30.         this.before = before;
    31.     }
    32.  
    33.     public Optional getAfter() {
    34.         return after;
    35.     }
    36.  
    37.     public void setAfter(Optional after) {
    38.         this.after = after;
    39.     }
    40. }
    1. package com.rulecheck.entity;
    2.  
    3. import java.util.Optional;
    4.  
    5. public class PaginationOptions {
    6.     private Optional size;
    7.     private Optional before;
    8.     private Optional after;
    9.  
    10.  
    11.     public PaginationOptions(Optional size, Optional before, Optional after) {
    12.         this.size = size;
    13.         this.before = before;
    14.         this.after = after;
    15.     }
    16.  
    17.     public Optional getSize() {
    18.         return size;
    19.     }
    20.  
    21.     public void setSize(Optional size) {
    22.         this.size = size;
    23.     }
    24.  
    25.     public Optional getBefore() {
    26.         return before;
    27.     }
    28.  
    29.     public void setBefore(Optional before) {
    30.         this.before = before;
    31.     }
    32.  
    33.     public Optional getAfter() {
    34.         return after;
    35.     }
    36.  
    37.     public void setAfter(Optional after) {
    38.         this.after = after;
    39.     }
    40. }
    1.  
    2.  
    3. import com.faunadb.client.types.FaunaConstructor;
    4. import com.faunadb.client.types.FaunaField;
    5.  
    6. public class TodoEntity extends Entity {
    7.  
    8.     @FaunaField
    9.     private String title;
    10.  
    11.     @FaunaField
    12.     private String description;
    13.  
    14.     @FaunaConstructor
    15.     public TodoEntity(@FaunaField("id") String id,
    16.                       @FaunaField("title") String title,
    17.                       @FaunaField("description") String description) {
    18.         this.id = id;
    19.         this.title = title;
    20.         this.description = description;
    21.  
    22.     }
    23.  
    24.     public void setTitle(String title) {
    25.         this.title = title;
    26.     }
    27.  
    28.     public String getTitle() {
    29.         return title;
    30.     }
    31.  
    32.     public String getDescription() {
    33.         return description;
    34.     }
    35.  
    36.     public void setDescription(String description) {
    37.         this.description = description;
    38.     }
    39. }
    1. package com.rulecheck.entity;
    2.  
    3. public class CreateOrUpdateTodoData {
    4.  
    5.     private String title;
    6.     private String description;
    7.  
    8.     public CreateOrUpdateTodoData(String title, String description) {
    9.         this.title = title;
    10.         this.description = description;
    11.     }
    12.  
    13.     public String getTitle() {
    14.         return title;
    15.     }
    16.  
    17.     public void setTitle(String title) {
    18.         this.title = title;
    19.     }
    20.  
    21.     public String getDescription() {
    22.         return description;
    23.     }
    24.  
    25.     public void setDescription(String description) {
    26.         this.description = description;
    27.     }
    28. }

    8.service及接口

    1. package com.rulecheck.service;
    2.  
    3. import com.faunadb.client.FaunaClient;
    4. import com.faunadb.client.errors.NotFoundException;
    5. import com.faunadb.client.query.Expr;
    6. import com.faunadb.client.query.Pagination;
    7. import com.faunadb.client.types.Value;
    8. import com.rulecheck.entity.Entity;
    9. import com.rulecheck.entity.Page;
    10. import com.rulecheck.entity.PaginationOptions;
    11. import jakarta.annotation.Resource;
    12.  
    13. import java.util.List;
    14. import java.util.Optional;
    15. import java.util.concurrent.CompletableFuture;
    16. import java.util.function.Function;
    17. import java.util.stream.Collectors;
    18.  
    19. import static com.faunadb.client.query.Language.*;
    20.  
    21. import java.lang.Class;
    22.  
    23. public abstract class FaunaRepositoryextends Entity > implements Repository, IdentityFactory {
    24.  
    25.     @Resource
    26.     private FaunaClient faunaClient;
    27.  
    28.     protected final Class entityType;
    29.     protected final String collectionName;
    30.     protected final String collectionIndexName;
    31.  
    32.  
    33.     protected FaunaRepository(Class entityType, String collectionName, String collectionIndexName) {
    34.         this.entityType = entityType;
    35.         this.collectionName = collectionName;
    36.         this.collectionIndexName = collectionIndexName;
    37.     }
    38.  
    39.     // This method returns a unique valid Id leveraging Fauna's NewId function.
    40.     @Override
    41.     public CompletableFuture nextId() {
    42.  
    43.         CompletableFuture result =
    44.                 faunaClient.query(
    45.                         NewId()
    46.                 )
    47.                         .thenApply(value -> value.to(String.class).get());
    48.  
    49.         return result;
    50.     }
    51.  
    52.     // This method saves an entity to the database using the saveQuery method below. It also returns the result of the saved entity.
    53.     @Override
    54.     public CompletableFuture save(T entity) {
    55.         CompletableFuture result =
    56.                 faunaClient.query(
    57.                         saveQuery(Value(entity.getId()), Value(entity))
    58.                 )
    59.                         .thenApply(this::toEntity);
    60.  
    61.         return result;
    62.     }
    63.  
    64.     // This method deletes from the data an entity(document) with the specified Id. 
    65.     @Override
    66.     public CompletableFuture> remove(String id) {
    67.         CompletableFuture result =
    68.                 faunaClient.query(
    69.                         Select(
    70.                                 Value("data"),
    71.                                 Delete(Ref(Collection(collectionName), Value(id)))
    72.                         )
    73.                 )
    74.                         .thenApply(this::toEntity);
    75.  
    76.         CompletableFuture> optionalResult = toOptionalResult(result);
    77.  
    78.         return optionalResult;
    79.     }
    80.  
    81.     // This method finds an entity by its Id and returns the entity result.
    82.     @Override
    83.     public CompletableFuture> find(String id) {
    84.         CompletableFuture result =
    85.                 faunaClient.query(
    86.                         Select(
    87.                                 Value("data"),
    88.                                 Get(Ref(Collection(collectionName), Value(id)))
    89.                         )
    90.                 )
    91.                         .thenApply(this::toEntity);
    92.  
    93.         CompletableFuture> optionalResult = toOptionalResult(result);
    94.  
    95.         return optionalResult;
    96.     }
    97.  
    98.     // This method returns all entities(documents) in the database collection using the paginationOptions parameters.
    99.     @Override
    100.     public CompletableFuture> findAll(PaginationOptions po) {
    101.         Pagination paginationQuery = Paginate(Match(Index(Value(collectionIndexName))));
    102.         po.getSize().ifPresent(size -> paginationQuery.size(size));
    103.         po.getAfter().ifPresent(after -> paginationQuery.after(Ref(Collection(collectionName), Value(after))));
    104.         po.getBefore().ifPresent(before -> paginationQuery.before(Ref(Collection(collectionName), Value(before))));
    105.  
    106.         CompletableFuture> result =
    107.                 faunaClient.query(
    108.                         Map(
    109.                                 paginationQuery,
    110.                                 Lambda(Value("nextRef"), Select(Value("data"), Get(Var("nextRef"))))
    111.                         )
    112.                 ).thenApply(this::toPage);
    113.  
    114.         return result;
    115.     }
    116.  
    117.  
    118.     // This is the saveQuery expression method used by the save method to persist the database.
    119.     protected Expr saveQuery(Expr id, Expr data) {
    120.         Expr query =
    121.                 Select(
    122.                         Value("data"),
    123.                         If(
    124.                                 Exists(Ref(Collection(collectionName), id)),
    125.                                 Replace(Ref(Collection(collectionName), id), Obj("data", data)),
    126.                                 Create(Ref(Collection(collectionName), id), Obj("data", data))
    127.                         )
    128.                 );
    129.  
    130.         return query;
    131.     }
    132.  
    133.     // This method converts a FaunaDB Value into an Entity.
    134.     protected T toEntity(Value value) {
    135.         return value.to(entityType).get();
    136.     }
    137.  
    138.     // This method returns an optionalResult from a CompletableFuture result.
    139.     protected CompletableFuture> toOptionalResult(CompletableFuture result) {
    140.         CompletableFuture> optionalResult =
    141.                 result.handle((v, t) -> {
    142.                     CompletableFuture> r = new CompletableFuture<>();
    143.                     if(v != null) r.complete(Optional.of(v));
    144.                     else if(t != null && t.getCause() instanceof NotFoundException) r.complete(Optional.empty());
    145.                     else r.completeExceptionally(t);
    146.                     return r;
    147.                 }).thenCompose(Function.identity());
    148.  
    149.         return optionalResult;
    150.     }
    151.  
    152.     // This method converts a FaunaDB Value into a Page with the Entity type.
    153.     protected Page toPage(Value value) {
    154.  
    155.         Optional after = value.at("after").asCollectionOf(Value.RefV.class).map(c -> c.iterator().next().getId()).getOptional();
    156.         Optional before = value.at("before").asCollectionOf(Value.RefV.class).map(c -> c.iterator().next().getId()).getOptional();
    157.  
    158.         List data = value.at("data").collect(entityType).stream().collect(Collectors.toList());
    159.  
    160.         Page page = new Page(data, before, after);
    161.  
    162.         return page;
    163.     }
    164.  
    165. }

    1. import java.util.concurrent.CompletableFuture;
    2.  
    3. public interface IdentityFactory {
    4.  
    5.     CompletableFuture nextId();
    6. }
    1.  
    2.  
    3. import com.rulecheck.entity.Entity;
    4. import com.rulecheck.entity.Page;
    5. import com.rulecheck.entity.PaginationOptions;
    6.  
    7. import java.util.Optional;
    8. import java.util.concurrent.CompletableFuture;
    9.  
    10. public interface Repositoryextends Entity> {
    11.  
    12.     // This method saves the given Entity into the Repository.
    13.     CompletableFuture save(T entity);
    14.  
    15.     // This method finds an Entity for the given Id
    16.     CompletableFuture> find(String id);
    17.  
    18.     // This method retrieves a Page of TodoEntity entities for the given PaginationOptions
    19.     CompletableFuture> findAll(PaginationOptions po);
    20.  
    21.     // This method finds the Entity for the given Id and removes it. If no Entity can be found for the given Id an empty result is returned.
    22.     CompletableFuture> remove(String id);
    23. }
    1. import com.rulecheck.entity.TodoEntity;
    2. import org.springframework.stereotype.Repository;
    3. @Repository
    4. public class TodoRepository extends FaunaRepository {
    5.  
    6.     public TodoRepository(){
    7.         super(TodoEntity.class, "todos", "all_todos");
    8.     }
    9.  
    10.     //-- Custom repository operations specific to the TodoEntity will go below --//
    11.  
    12. }

    1.  
    2.  
    3. import com.rulecheck.entity.CreateOrUpdateTodoData;
    4. import com.rulecheck.entity.Page;
    5. import com.rulecheck.entity.PaginationOptions;
    6. import com.rulecheck.entity.TodoEntity;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.stereotype.Service;
    9.  
    10. import java.util.Optional;
    11. import java.util.concurrent.CompletableFuture;
    12.  
    13. @Service
    14. public class TodoService {
    15.  
    16.     @Autowired
    17.     private TodoRepository todoRepository;
    18.  
    19.     public CompletableFuture createTodo(CreateOrUpdateTodoData data) {
    20.         CompletableFuture result =
    21.                 todoRepository.nextId()
    22.                         .thenApply(id -> new TodoEntity(id, data.getTitle(), data.getDescription()))
    23.                         .thenCompose(todoEntity -> todoRepository.save(todoEntity));
    24.  
    25.         return result;
    26.     }
    27.  
    28.     public CompletableFuture> getTodo(String id) {
    29.         return todoRepository.find(id);
    30.     }
    31.  
    32.     public CompletableFuture> updateTodo(String id, CreateOrUpdateTodoData data) {
    33.         CompletableFuture> result =
    34.                 todoRepository.find(id)
    35.                         .thenCompose(optionalTodoEntity ->
    36.                                 optionalTodoEntity
    37.                                         .map(todoEntity -> todoRepository.save(new TodoEntity(id, data.getTitle(), data.getDescription())).thenApply(Optional::of))
    38.                                         .orElseGet(() -> CompletableFuture.completedFuture(Optional.empty())));
    39.  
    40.         return result;
    41.     }
    42.  
    43.     public CompletableFuture> deleteTodo(String id) {
    44.         return todoRepository.remove(id);
    45.     }
    46.  
    47.     public CompletableFuture> getAllTodos(PaginationOptions po) {
    48.         return todoRepository.findAll(po);
    49.     }
    50. }
    1. import com.faunadb.client.FaunaClient;
    2. import lombok.extern.slf4j.Slf4j;
    3. import org.springframework.beans.factory.annotation.Value;
    4. import org.springframework.beans.factory.config.ConfigurableBeanFactory;
    5. import org.springframework.boot.SpringApplication;
    6. import org.springframework.boot.autoconfigure.SpringBootApplication;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Scope;
    9.  
    10.  
    11. /**
    12.  * description:
    13.  */
    14.  
    15. @Slf4j
    16. @SpringBootApplication
    17. public class RuleCheckApplication {
    18.  
    19.     @Value("${fauna-db.secret}")
    20.     private String serverKey;
    21.  
    22.     @Bean
    23.     @Scope(value = ConfigurableBeanFactory.SCOPE_SINGLETON)
    24.     public FaunaClient faunaConfiguration() {
    25.         log.info("serverKey:{}", serverKey);
    26.         FaunaClient faunaClient = FaunaClient.builder()
    27.                 .withSecret(serverKey)
    28.                 .build();
    29.  
    30.         return faunaClient;
    31.     }
    32.  
    33.     public static void main(String[] args) {
    34.         SpringApplication.run(RuleCheckApplication.class, args);
    35.     }
    36.  
    37. }

    9.属性文件配置属性

    fauna-db.secret=fnAFN6K4SxAAQWm.........  自己生成数据库秘钥，非账户秘钥或者密码

    10.controller

    1. package com.rulecheck.controller;
    2.  
    3.  
    4. import com.rulecheck.entity.CreateOrUpdateTodoData;
    5. import com.rulecheck.entity.Page;
    6. import com.rulecheck.entity.PaginationOptions;
    7. import com.rulecheck.entity.TodoEntity;
    8. import com.rulecheck.service.TodoService;
    9. import org.springframework.beans.factory.annotation.Autowired;
    10. import org.springframework.http.HttpStatus;
    11. import org.springframework.http.ResponseEntity;
    12. import org.springframework.web.bind.annotation.*;
    13.  
    14. import java.util.Optional;
    15. import java.util.concurrent.CompletableFuture;
    16.  
    17. @RestController
    18. public class TodoRestController {
    19.  
    20.     @Autowired
    21.     private TodoService todoService;
    22.  
    23.  
    24.     @PostMapping("/todos")
    25.     public CompletableFuture createTodo(@RequestBody CreateOrUpdateTodoData data) {
    26.  
    27.         return todoService.createTodo(data)
    28.                 .thenApply(todoEntity -> new ResponseEntity(todoEntity, HttpStatus.CREATED));
    29.     }
    30.  
    31.  
    32.     @GetMapping("/todos/{id}")
    33.     public CompletableFuture getTodo(@PathVariable("id") String id) {
    34.         CompletableFuture result =
    35.                 todoService.getTodo(id)
    36.                         .thenApply(optionalTodoEntity ->
    37.                                 optionalTodoEntity
    38.                                         .map(todoEntity -> new ResponseEntity(todoEntity, HttpStatus.OK))
    39.                                         .orElseGet(() -> new ResponseEntity(HttpStatus.NOT_FOUND))
    40.                         );
    41.         return result;
    42.     }
    43.  
    44.  
    45.     @PutMapping("/todos/{id}")
    46.     public CompletableFuture updateTodo(@PathVariable("id") String id, @RequestBody CreateOrUpdateTodoData data) {
    47.         CompletableFuture result =
    48.                 todoService.updateTodo(id, data)
    49.                         .thenApply(optionalTodoEntity ->
    50.                                 optionalTodoEntity
    51.                                         .map(todoEntity -> new ResponseEntity(todoEntity, HttpStatus.OK))
    52.                                         .orElseGet(() -> new ResponseEntity(HttpStatus.NOT_FOUND)
    53.                                         )
    54.                         );
    55.         return result;
    56.     }
    57.  
    58.     @DeleteMapping(value = "/todos/{id}")
    59.     public CompletableFuture deletePost(@PathVariable("id")String id) {
    60.         CompletableFuture result =
    61.                 todoService.deleteTodo(id)
    62.                         .thenApply(optionalTodoEntity ->
    63.                                 optionalTodoEntity
    64.                                         .map(todo -> new ResponseEntity(todo, HttpStatus.OK))
    65.                                         .orElseGet(() -> new ResponseEntity(HttpStatus.NOT_FOUND)
    66.                                         )
    67.                         );
    68.         return result;
    69.     }
    70.  
    71.     @GetMapping("/todos")
    72.     public CompletableFuture> getAllTodos(
    73.             @RequestParam("size") Optional size,
    74.             @RequestParam("before") Optional before,
    75.             @RequestParam("after") Optional after) {
    76.         PaginationOptions po = new PaginationOptions(size, before, after);
    77.         CompletableFuture> result = todoService.getAllTodos(po);
    78.         return result;
    79.     }
    80. }

    11. 参考pom依赖

    1.     <parent>
    2.         <groupId>org.springframework.bootgroupId>
    3.         <artifactId>spring-boot-starter-parentartifactId>
    4.         <version>3.1.3version>
    5.         <relativePath>relativePath>
    6.     parent>
    7.     <properties>
    8.         <maven.compiler.source>8maven.compiler.source>
    9.         <maven.compiler.target>8maven.compiler.target>
    10.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    11.         <mybatis-plus-boot-starter>3.5.3.1mybatis-plus-boot-starter>
    12.         <mysql-connector-java>8.0.28mysql-connector-java>
    13.         <commons-io>2.11.0commons-io>
    14.     properties>
    16.     <dependencies>
    17.         <dependency>
    18.             <groupId>org.springframework.bootgroupId>
    19.             <artifactId>spring-boot-starter-webartifactId>
    20.         dependency>
    21.         <dependency>
    22.             <groupId>com.baomidougroupId>
    23.             <artifactId>mybatis-plus-boot-starterartifactId>
    24.             <version>${mybatis-plus-boot-starter}version>
    25.         dependency>
    26.         <dependency>
    27.             <groupId>mysqlgroupId>
    28.             <artifactId>mysql-connector-javaartifactId>
    29.            <version>${mysql-connector-java}version>
    30.         dependency>
    31.  
    32.         <dependency>
    33.             <groupId>com.baomidougroupId>
    34.             <artifactId>mybatis-plus-generatorartifactId>
    35.             <version>${mybatis-plus-boot-starter}version>
    36.         dependency>
    37.         <dependency>
    38.             <groupId>org.springframework.bootgroupId>
    39.             <artifactId>spring-boot-starter-data-redisartifactId>
    40.         dependency>
    41.  
    42.         <dependency>
    43.             <groupId>com.github.ben-manes.caffeinegroupId>
    44.             <artifactId>caffeineartifactId>
    45.         dependency>
    46.  
    47.         <dependency>
    48.             <groupId>commons-iogroupId>
    49.             <artifactId>commons-ioartifactId>
    50.             <version>${commons-io}version>
    51.         dependency>
    52.  
    53.         <dependency>
    54.             <groupId>org.projectlombokgroupId>
    55.             <artifactId>lombokartifactId>
    56.             <version>1.18.28version>
    57.             <scope>providedscope>
    58.         dependency>
    59.         <dependency>
    60.             <groupId>com.faunadbgroupId>
    61.             <artifactId>faunadb-javaartifactId>
    62.             <version>4.4.0version>
    63.             <scope>compilescope>
    64.         dependency>
    65.     dependencies>

    11.启动后postman试试

    http://localhost:8080/todos

    {

        "title":"create a job",

        "description":"this post request is todos"

    }

  • 相关阅读:
    【三十】springboot项目上高并发解决示例
    [附源码]计算机毕业设计学生综合数据分析系统Springboot程序
    网络安全（黑客）自学
    WinCC趋势跨度设置（时间范围）
    MATLAB图像处理介绍
    [Spring] Spring5——IOC 简介（二）
    IDEA 集成 Github（八）——Git
    Python编程语言学习：shap.force_plot函数的源码解读之详细攻略
    导包问题解决--ImportError: DLL load failed while importing _path: 找不到指定的模块
    iNFTnews｜NFT和艺术有何区别？
  • 原文地址：https://blog.csdn.net/haohaounique/article/details/132913153