spring r2dbc中的创建表

@Table("users")
public class User {
    @Id
    private Long id;
    
    @Column("name")
    private String name;
    
    @Column("age")
    private Integer age;
    
    // getters and setters
}

public interface UserRepository extends ReactiveCrudRepository<User, Long> {
}

CREATE TABLE users (
    id SERIAL PRIMARY KEY,
    name VARCHAR(255),
    age INTEGER
);

@Service
public class UserService {
    private final UserRepository userRepository;
    
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }
    
    public Flux<User> getAllUsers() {
        return userRepository.findAll();
    }
    
    public Mono<User> createUser(User user) {
        return userRepository.save(user);
    }
    
    // 其他数据库操作方法
}