XmlSqlService 자기 참조 빈

src/main/java/springbook/chapter07/SqlRetrievalFailureException.java

@@ -8,4 +8,8 @@ public SqlRetrievalFailureException(String message) {
     public SqlRetrievalFailureException(String message, Throwable cause) {
         super(message, cause);
     }
+
+    public SqlRetrievalFailureException(Throwable cause) {
+        super(cause);
+    }
 }

src/main/java/springbook/chapter07/TestDBConfig.java

@@ -92,6 +92,8 @@ public UserDaoJdbc userDao(){
     public SqlService sqlService() {
         XmlSqlService sqlService = new XmlSqlService();
         sqlService.setSqlmapFile("sqlmap.xml");
+        sqlService.setSqlReader(sqlService);
+        sqlService.setSqlRegistry(sqlService);
         return sqlService;
     }
 

src/main/java/springbook/chapter07/XmlSqlService.java

@@ -2,6 +2,9 @@
 
 import springbook.chapter07.jaxb.SqlType;
 import springbook.chapter07.jaxb.Sqlmap;
+import springbook.chapter07.sqlService.SqlNotFoundException;
+import springbook.chapter07.sqlService.SqlReader;
+import springbook.chapter07.sqlService.SqlRegistry;
 
 import javax.annotation.PostConstruct;
 import javax.xml.bind.JAXBContext;
@@ -11,17 +14,32 @@
 import java.util.HashMap;
 import java.util.Map;
 
-public class XmlSqlService implements SqlService {
+public class XmlSqlService implements SqlService, SqlRegistry, SqlReader {
 
     private final Map<String , String> sqlMap = new HashMap<>();
+    private SqlReader sqlReader;
+    private SqlRegistry sqlRegistry;
     private String sqlmapFile;
 
+    public void setSqlReader(SqlReader sqlReader) {
+        this.sqlReader = sqlReader;
+    }
+
+    public void setSqlRegistry(SqlRegistry sqlRegistry) {
+        this.sqlRegistry = sqlRegistry;
+    }
+
     public void setSqlmapFile(String sqlmapFile) {
         this.sqlmapFile = sqlmapFile;
     }
 
     @PostConstruct
-    private void loadSql() {
+    public void loadSql() {
+        this.sqlReader.read(this.sqlRegistry);
+    }
+
+    @Override
+    public void read(SqlRegistry sqlRegistry) {
         String contextPath = Sqlmap.class.getPackage().getName();
         try {
             JAXBContext jaxbContext = JAXBContext.newInstance(contextPath);
@@ -30,7 +48,7 @@ private void loadSql() {
             Sqlmap sqlmap = (Sqlmap) unmarshaller.unmarshal(is);
 
             for (SqlType sql : sqlmap.getSql()) {
-                this.sqlMap.put(sql.getKey(), sql.getValue());
+                sqlRegistry.registerSql(sql.getKey(), sql.getValue());
             }
         } catch (JAXBException e) {
             // JAXBException은 복구 불가능한 예외이기 때문에 RuntimeException으로 포장해서 던진다
@@ -40,9 +58,23 @@ private void loadSql() {
 
     @Override
     public String getSql(String key) throws SqlRetrievalFailureException {
+        try {
+            return this.sqlRegistry.findSql(key);
+        } catch (SqlNotFoundException e) {
+            throw new SqlRetrievalFailureException(e);
+        }
+    }
+
+    @Override
+    public void registerSql(String key, String sql) {
+        sqlMap.put(key, sql);
+    }
+
+    @Override
+    public String findSql(String key) throws SqlNotFoundException {
         String sql = sqlMap.get(key);
         if (sql == null) {
-            throw new SqlRetrievalFailureException(key + "를 이용해서 SQL을 찾을 수 없습니다.");
+            throw new SqlNotFoundException(key + "에 대한 SQL을 찾을 수 없습니다.");
         }
         return sql;
     }

src/main/java/springbook/chapter07/sqlService/SqlNotFoundException.java

@@ -0,0 +1,7 @@
+package springbook.chapter07.sqlService;
+
+public class SqlNotFoundException extends RuntimeException {
+    public SqlNotFoundException(String message) {
+        super(message);
+    }
+}

src/main/java/springbook/chapter07/sqlService/SqlReader.java

@@ -0,0 +1,6 @@
+package springbook.chapter07.sqlService;
+
+public interface SqlReader {
+
+    void read(SqlRegistry sqlRegistry);
+}

src/main/java/springbook/chapter07/sqlService/SqlRegistry.java

@@ -0,0 +1,20 @@
+package springbook.chapter07.sqlService;
+
+public interface SqlRegistry {
+    /**
+     * SQL을 키와 함께 등록한다.
+     *
+     * @param key
+     * @param sql
+     */
+    void registerSql(String key, String sql);
+
+    /**
+     * 키에 해당하는 SQL을 조회한다.
+     *
+     * @param key
+     * @return 찾은 SQL
+     * @throws SqlNotFoundException
+     */
+    String findSql(String key) throws SqlNotFoundException;
+}