在事务中执行 Dataflow 读取操作

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

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

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

• 使用 Dataflow 连接器

代码示例

Java

在 GitHub 上查看 反馈

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));