spring r2dbc에서 mysql SELECT LAST_INSERT_ID() 함수 호출 질문입니다

Question

에러가 나는 코드는 아닙니다 databaseClient, ReactiveCrudRepository 둘 다 insert는 되지만 SELECT LAST_INSERT_ID() 요 쿼리문 결과가 0이 나옵니다 혹시나 Transaction문제일까봐 넣었는데도 안됩니다 아 repository.getLastId는 ReactiveCrudRepository 상속받은걸로 했습니다 @Query("SELECT LAST_INSERT_ID()")public Mono getLastId(); System.out.println( elem.getKey()); LAST_INSERT_ID() 결과System.out.println( elem.getValue()); 0 결과 ///링크https://javacan.tistory.com/entry/R2DBC-03-Spring-Data-R2DBC-DatabaseClient?category=699082 // Transaction 선언 부분 @EnableTransactionManagement@Configurationpublic class R2dbcConfig extends AbstractR2dbcConfiguration { @Override @Bean public ConnectionFactory connectionFactory() { String url = "r2dbcs:mysql://scott:tiger@localhost:3306/bidding"; ConnectionFactory connectionFactory = ConnectionFactories.get(url); return connectionFactory; } @Bean ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) { return new R2dbcTransactionManager(connectionFactory); }} //함수@Transactional public Mono insert(ServerRequest req) { Mono mbody = req.bodyToMono(RequestGetter.class); Mono rs = mbody.flatMap(mBody -> { /* 1번 return databaseClient .execute("insert into Request(category, context , uploadAt, deadLine, hopeDate, user_indexId )" + "values ( :category, :context , :uploadAt, :deadLine, :hopeDate, :user_indexId)") .bind("category", mBody.getCategory()) .bind("context", mBody.getContext()) .bind("uploadAt", GetTimeZone.getSeoulDate()) .bind("deadLine", mBody.getDeadline()) .bind("hopeDate", mBody.getHopeDate()) .bind("user_indexId", mBody.getUserId()) .fetch() .rowsUpdated() .onErrorReturn(-1); }).then(databaseClient.execute("SELECT LAST_INSERT_ID()") .fetch().first().flatMap(m -> { for (Entry elem : m.entrySet()) { System.out.println( elem.getKey()); System.out.println( elem.getValue()); } return Mono.just(1); }) .onErrorReturn(-1));*/ 2번 return requestRepository.requestInsert( mBody.getCategory(), mBody.getContext(), GetTimeZone.getSeoulDate(), mBody.getDeadline(), mBody.getHopeDate(), mBody.getUserId() ).then(requestRepository.getLastId() .flatMap(m -> { System.out.println(m); return Mono.just(m); }).onErrorReturn(-1)); }); return ok().body( rs, Request.class); }

spring r2dbc에서 mysql SELECT LAST_INSERT_ID() 함수 호출 질문입니다

0개의 답변

#r2dbc 목록