Spring Data R2DBC测试：@Sql失效替代方案及类似@Sql查询执行方法

别着急，我帮你一步步解决这两个问题——先排查@Sql注解不生效的原因，再给你讲Spring Data R2DBC里实现类似测试数据初始化的方案：

先从最基础的细节开始排查，大概率是某个配置环节没到位：

• 确认注解包导入正确：一定要用org.springframework.test.context.jdbc.Sql，别不小心导入了其他框架的同名注解（比如JPA相关的），包路径错了注解肯定不会被Spring解析。
• 检查SQL文件的路径和内容：
  • 默认情况下，Spring会从src/test/resources目录下查找SQL文件，如果你放的位置特殊，要写全相对路径，比如@Sql("/sql/insert.sql")（开头的斜杠代表资源根路径）。
  • 手动在数据库里跑一遍insert.sql的内容，确认语法没问题——比如有没有漏写分号、字段/表名拼写错误，SQL本身执行失败的话，注解自然不会有预期效果。
• 验证测试类的上下文配置：
  • 测试类必须标注@SpringBootTest（Spring Boot项目）或者@ContextConfiguration（传统Spring项目），确保Spring上下文能正常加载，不然注解根本不会被触发。
  • 如果测试方法用了@Transactional，注意默认是测试结束后回滚数据的——你可以在测试方法里加个断点，实时查询数据库看看数据有没有真的插入，别误以为注解没生效。
• 确认SQL执行时机：@Sql默认是在测试方法执行前运行（executionPhase = BEFORE_TEST_METHOD），如果不小心修改了这个属性，比如设成了AFTER_TEST_METHOD，就会在方法结束后执行，显式指定一下更稳妥：

  @Sql(executionPhase = Sql.ExecutionPhase.BEFORE_TEST_METHOD, scripts = "insert.sql")
  

• 开日志找线索：把Spring JDBC的日志级别调到DEBUG，比如在application-test.yml里配置：

  logging:
    level:
      org.springframework.jdbc: DEBUG
  

  查看日志里有没有加载SQL文件、执行SQL的记录——如果连文件都没找到，就是路径问题；如果执行报错，就根据错误信息定位具体问题。

因为R2DBC是响应式数据库框架，Spring Test的@Sql并不支持响应式场景，所以得用以下几种替代方案：

• 方案一：用@TestConfiguration初始化数据
  写一个测试专属的配置类，注入DatabaseClient，在Spring上下文加载时自动执行初始化SQL：

  @TestConfiguration
  public class TestDataInitializer {
      public TestDataInitializer(DatabaseClient databaseClient) {
          // 执行单条SQL
          databaseClient.sql("INSERT INTO user (id, name) VALUES (1, 'test_user')")
              .fetch()
              .rowsUpdated()
              .block(); // 阻塞等待执行完成，因为上下文初始化是同步流程
  
          // 如果是执行SQL文件，可读取文件内容后执行
          // String sqlContent = Files.readString(Paths.get("src/test/resources/insert.sql"));
          // databaseClient.sql(sqlContent).fetch().rowsUpdated().block();
      }
  }
  

  然后在测试类里导入这个配置：@Import(TestDataInitializer.class)，这样每次测试上下文启动都会自动执行数据初始化。

• 方案二：自定义注解+@BeforeEach
  封装一个类似@Sql的自定义注解，结合@BeforeEach处理脚本执行，复用性更强：

  // 自定义响应式SQL注解
  @Target(ElementType.METHOD)
  @Retention(RetentionPolicy.RUNTIME)
  public @interface R2dbcSql {
      String[] scripts() default {};
  }
  
  // 测试类中的处理逻辑
  @SpringBootTest
  public class UserRepositoryTest {
      @Autowired
      private DatabaseClient databaseClient;
      @Autowired
      private ResourceLoader resourceLoader;
  
      @BeforeEach
      void setupTestData(Method testMethod) {
          R2dbcSql r2dbcSql = testMethod.getAnnotation(R2dbcSql.class);
          if (r2dbcSql != null) {
              for (String script : r2dbcSql.scripts()) {
                  try {
                      // 读取classpath下的SQL文件
                      Resource resource = resourceLoader.getResource("classpath:" + script);
                      String sql = Files.readString(resource.getFile().toPath());
                      // 执行SQL脚本
                      databaseClient.sql(sql)
                          .fetch()
                          .rowsUpdated()
                          .block();
                  } catch (IOException e) {
                      throw new RuntimeException("Failed to read SQL script: " + script, e);
                  }
              }
          }
      }
  
      // 使用自定义注解
      @R2dbcSql(scripts = "insert.sql")
      @Test
      void testFindUserById() {
          // 你的测试逻辑
      }
  }
  

• 方案三：Testcontainers配合初始化脚本
  如果用Testcontainers启动测试用的数据库容器，可以直接指定初始化脚本，容器启动时自动执行：

  @Container
  public static PostgreSQLContainer<?> postgresContainer = new PostgreSQLContainer<>("postgres:15")
      .withInitScript("insert.sql"); // 脚本放在src/test/resources目录下
  

  这种方式最省心，容器启动时就会把脚本里的SQL执行完成，测试直接使用即可。

内容的提问来源于stack exchange，提问作者Amuzr