RedisGraph 属性持久化：有效处理 JSON 中的单引号与转义双引号

GRAPH.QUERY movies "CREATE (:Actor {name:"Peter O'Toole", desc:"An "actors" actor", actor_id:1})"

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.core.json.JsonWriteFeature;

// 假设 Person 类定义如下：
class Person {
    public String firstname;
    public String lastname;
    public String desc;
    // 构造函数和 Getter/Setter 省略
    public Person(String firstname, String lastname) {
        this.firstname = firstname;
        this.lastname = lastname;
    }
    public void setDesc(String desc) {
        this.desc = desc;
    }
}

public class JsonProcessor {
    public static void main(String[] args) throws Exception {
        ObjectMapper objectMapper = new ObjectMapper();

        // (可选) 启用 JSON 美化输出
        objectMapper.enable(SerializationFeature.INDENT_OUTPUT);

        // (可选) 不对属性名加引号，这有助于直接生成类似 Cypher 的属性语法
        // 但对于本教程，我们主要关注属性值
        // objectMapper.configure(JsonWriteFeature.QUOTE_FIELD_NAMES.mappedFeature(), false);

        // 创建一个 Person 对象，其属性包含单引号和转义双引号
        Person person = new Person("Peter", "O'Toole");
        person.setDesc("An "actor's" actor"); // 注意：在 Java 字符串中，" 表示一个双引号字符

        // 将 Person 对象转换为 JSON 字符串
        String json = objectMapper.writeValueAsString(person);

        System.out.println("生成的 JSON 字符串:");
        System.out.println(json);
    }
}

生成的 JSON 字符串:
{
  "firstname" : "Peter",
  "lastname" : "O'Toole",
  "desc" : "An "actor's" actor"
}

// 假设我们已经从 Person 对象获取了这些字符串值
String firstname = "Peter";
String lastname = "O'Toole";
String desc = "An "actor's" actor"; // 这个 Java 字符串实际内容是 "An "actor's" actor"

// 构建 Cypher 命令字符串
// 注意 Java 字符串字面量中对双引号的额外转义：
// Cypher 中的 "Peter" 对应 Java 的 ""Peter""
// Cypher 中的 "O'Toole" 对应 Java 的 ""O'Toole""
// Cypher 中的 "An "actor's" actor" 对应 Java 的 ""An \"actor's\" actor""
String cmdStr = String.format(
    "CREATE (:Actor {firstname:"%s", lastname: "%s", desc:"%s", actor_id:%d})",
    firstname,
    lastname,
    desc.replace(""", "\""), // 将 desc 中实际的双引号转义为 Cypher 格式的 "
    1
);

System.out.println("构建的 Cypher 命令字符串:");
System.out.println(cmdStr);

构建的 Cypher 命令字符串:
CREATE (:Actor {firstname:"Peter", lastname: "O'Toole", desc:"An "actor's" actor", actor_id:1})

import io.vertx.core.Future;
import io.vertx.core.Vertx;
import io.vertx.redis.client.Command;
import io.vertx.redis.client.Redis;
import io.vertx.redis.client.Request;

public class RedisGraphClient {

    private final Redis redisClient;

    public RedisGraphClient(Vertx vertx) {
        this.redisClient = Redis.createClient(vertx);
    }

    public Future<String> createActor(String firstname, String lastname, String desc, int actorId) {
        // 构建 Cypher 命令字符串
        // 注意：这里的 desc.replace(""", "\"") 是为了确保 Cypher 字符串中的内部双引号被正确转义
        String cypherDesc = desc.replace(""", "\"");
        String cmdStr = String.format(
            "CREATE (:Actor {firstname:"%s", lastname: "%s", desc:"%s", actor_id:%d})",
            firstname,
            lastname,
            cypherDesc,
            actorId
        );

        System.out.println("发送到 RedisGraph 的命令: " + cmdStr);

        return redisClient.send(Request.cmd(Command.GRAPH_QUERY).arg("movies").arg(cmdStr))
            .compose(response -> {
                System.out.println("createRequest 响应: " + response.toString());
                return Future.succeededFuture("OK");
            })
            .onFailure(failure -> {
                System.err.println("createRequest 失败: " + failure.getMessage());
            });
    }

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();
        RedisGraphClient client = new RedisGraphClient(vertx);

        // 示例数据
        String firstname = "Peter";
        String lastname = "O'Toole";
        String desc = "An "actor's" actor"; // 实际的 Java 字符串值
        int actorId = 1;

        client.createActor(firstname, lastname, desc, actorId)
            .onComplete(ar -> {
                if (ar.succeeded()) {
                    System.out.println("Actor 创建成功: " + ar.result());
                } else {
                    System.err.println("Actor 创建失败: " + ar.cause().getMessage());
                }
                vertx.close(); // 关闭 Vertx 实例
            });
    }
}