【发布时间】:2021-04-14 05:33:43
【问题描述】:
我尝试重复course 中的代码。 应该为初始化创建 SQL 查询并在 public void setup() 中运行,但我遇到了一些问题:
- 无法解析“DatabaseClient”中的“execute”方法
- 对“create”的引用不明确,“create(Publisher extends T>)”和“create(Publisher extends T>, long)”都匹配
代码
@BeforeAll
public void setup() {
Hooks.onOperatorDebug();
List<String> statements = Arrays.asList(//
"DROP TABLE IF EXISTS player;",
"CREATE table player (id INT AUTO_INCREMENT NOT NULL, name VARCHAR2, age INT NOT NULL);");
statements.forEach(it -> client.execute(it) //
.fetch() //
.rowsUpdated() //
.as(StepVerifier::create) //
.expectNextCount(1) //
.verifyComplete());
}
【问题讨论】:
-
使用文章中提到的确切库版本。 API 可以更改。
标签: java spring spring-data spring-data-r2dbc r2dbc