在Spring Data R2DBC上初始化数据库以进行测试

import org.junit.Before;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.data.r2dbc.DataR2dbcTest;
import org.springframework.r2dbc.core.DatabaseClient;

@DataR2dbcTest
public class DatabaseInitializationTest {

    @Autowired
    private DatabaseClient databaseClient;

    @Before
    public void setup() {
        // 执行数据库初始化操作，可以使用execute方法执行SQL语句或者数据库迁移工具
        databaseClient.execute("CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(255))")
                .fetch()
                .rowsUpdated()
                .block();
    }

    @Test
    public void testDatabaseInitialization() {
        // 编写具体的测试逻辑，验证数据库的初始化结果
        // 可以使用Spring Data R2DBC提供的各种查询方法来查询数据库中的数据
    }
}