Skip to content

Commit

Permalink
#564 [feat] sql 로깅 모듈 구현
Browse files Browse the repository at this point in the history
  • Loading branch information
sohyundoh committed Nov 3, 2024
1 parent 2c3ed80 commit a77f1a4
Show file tree
Hide file tree
Showing 4 changed files with 82 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -0,0 +1,33 @@
package com.mile.common.log;

import com.p6spy.engine.logging.Category;
import com.p6spy.engine.spy.appender.MessageFormattingStrategy;
import org.hibernate.engine.jdbc.internal.FormatStyle;
import org.slf4j.MDC;

import java.util.Locale;

public class P6spySqlFormat implements MessageFormattingStrategy {
private final String MDC_KEY = "SQL_START";

@Override
public String formatMessage(int connectionId, String now, long elapsed, String category, String prepared, String sql, String url) {
sql = formatSql(category, sql);
return MDC.get(MDC_KEY) + "|" + sql;
}

private String formatSql(String category, String sql) {
if (sql == null || sql.trim().equals("")) return sql;

if (Category.STATEMENT.getName().equals(category)) {
String tmpsql = sql.trim().toLowerCase(Locale.ROOT);
if (tmpsql.startsWith("create") || tmpsql.startsWith("alter") || tmpsql.startsWith("comment")) {
sql = FormatStyle.DDL.getFormatter().format(sql);
} else {
sql = FormatStyle.BASIC.getFormatter().format(sql);
}
}

return sql;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
package com.mile.common.log;

import com.p6spy.engine.spy.P6SpyOptions;
import jakarta.annotation.PostConstruct;
import org.springframework.context.annotation.Configuration;

@Configuration
public class P6spySqlFormatConfig {

@PostConstruct
public void setLogMessageFormat() {
P6SpyOptions.getActiveInstance().setLogMessageFormat(P6spySqlFormat.class.getName());
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
package com.mile.common.log;

import lombok.AccessLevel;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.MDC;
import org.springframework.stereotype.Component;

/**
* from @sohyundoh
* <p>
* SQL 진입점을 로깅하기 위한 AOP 클래스
*/
@Aspect
@Component
@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
@Slf4j
public class SqlFunctionLoggingModule {
private final String MDC_KEY = "SQL_START";

@Pointcut("execution(* com.mile.*.repository..*.*(..))")
public void sqlLoggingPoint() {
}

@Around("sqlLoggingPoint()")
public Object putSqlStartingPoint(final ProceedingJoinPoint joinPoint) throws Throwable {
MDC.put(MDC_KEY, "[ QUERY START -> " + joinPoint.getSignature().toShortString() + "]");

return joinPoint.proceed();
}
}
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
package com.mile.moim.repository;

import com.mile.moim.domain.Moim;
import com.mile.post.domain.Post;
import com.mile.writername.domain.WriterName;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.JpaRepository;
Expand Down

0 comments on commit a77f1a4

Please sign in to comment.