// MySQL 연결 설정 구성
MySqlConnectionConfiguration configuration = MySqlConnectionConfiguration.builder()
    .host("localhost")             // MySQL 서버 호스트
    .port(3306)                    // MySQL 서버 포트 (기본값: 3306)
    .username("root")              // MySQL 사용자 이름
    .password("password")          // MySQL 사용자 비밀번호
    .database("test_db")           // 사용할 데이터베이스 이름
    .build();

// MySQL 연결 팩토리 생성
MySqlConnectionFactory connectionFactory = MySqlConnectionFactory.from(configuration);

// 연결을 통해 트랜잭션 시작, 쿼리 실행, 커밋 또는 롤백 수행
connectionFactory.create()
    .flatMap(connection -> 
        connection.beginTransaction()   // 트랜잭션 시작
            .then(connection.createStatement("INSERT INTO users (name, email) VALUES (?, ?)")
            .bind(0, "John Doe")         // 첫 번째 파라미터 바인딩
            .bind(1, "john.doe@example.com") // 두 번째 파라미터 바인딩
            .execute())                  // 쿼리 실행
            .then(connection.commitTransaction())  // 성공 시 트랜잭션 커밋
            .onErrorResume(e -> 
                connection.rollbackTransaction()    // 오류 발생 시 롤백
                .then(Mono.error(e))                // 오류 전달
            )
            .then(connection.close())    // 작업 완료 후 연결 닫기
    ).subscribe();