在事务中执行 Dataflow 读取操作

使用 Dataflow 连接器在同一时间从多个表读取数据，以便通过在单个事务中执行所有读取操作来确保数据一致性。

包含此代码示例的文档页面

如需查看上下文中使用的代码示例，请参阅以下文档：

使用 Dataflow 连接器

代码示例

Java

如需了解如何安装和使用 Cloud Spanner 客户端库，请参阅 Cloud Spanner 客户端库。

SpannerConfig spannerConfig = SpannerConfig.create()
    .withInstanceId(instanceId)
    .withDatabaseId(databaseId);
PCollectionView<Transaction> tx = p.apply(
    SpannerIO.createTransaction()
        .withSpannerConfig(spannerConfig)
        .withTimestampBound(TimestampBound.strong()));
PCollection<Struct> singers = p.apply(SpannerIO.read()
    .withSpannerConfig(spannerConfig)
    .withQuery("SELECT SingerID, FirstName, LastName FROM Singers")
    .withTransaction(tx));
PCollection<Struct> albums = p.apply(SpannerIO.read().withSpannerConfig(spannerConfig)
    .withQuery("SELECT SingerId, AlbumId, AlbumTitle FROM Albums")
    .withTransaction(tx));

后续步骤

如需搜索和过滤其他 Google Cloud 产品的代码示例，请参阅 Google Cloud 示例浏览器