From e2c60caab32e51868766541e758e8defd792f36e Mon Sep 17 00:00:00 2001
From: mhyeon-lee <mhyeon.lee@navercorp.com>
Date: Sun, 24 Jan 2021 17:24:23 +0900
Subject: [PATCH] Fix @SqlTableAlias alias name apply to column alias

(cherry picked from commit 4f097f666e87c9c07de967976f6cd19b06036a6d)
---
 .../data/jdbc/plus/sql/guide/board/Board.java |  3 +
 .../jdbc/plus/sql/guide/board/PostDto.java    |  2 +
 .../plus/sql/guide/board/sql/BoardSql.groovy  |  4 +-
 .../data/jdbc/plus/sql/guide/board/Board.java |  3 +
 .../jdbc/plus/sql/guide/board/PostDto.java    |  3 +
 .../jdbc/plus/sql/guide/board/sql/BoardSql.kt |  4 +-
 .../data/jdbc/plus/sql/guide/board/Board.kt   |  2 +
 .../data/jdbc/plus/sql/guide/board/PostDto.kt |  2 +
 .../jdbc/plus/sql/guide/board/sql/BoardSql.kt |  4 +-
 .../convert/AggregateResultJdbcConverter.java | 11 ++-
 ...dbcBackReferencePropertyValueProvider.java |  6 +-
 .../convert/JdbcPropertyValueProvider.java    |  3 +-
 .../plus/sql/convert/PropertyPathUtils.java   | 96 +++++++++++++++++++
 .../jdbc/plus/sql/convert/SqlContext.java     | 65 ++-----------
 .../plus/sql/convert/SqlProviderTest.java     | 73 +++++++++-----
 15 files changed, 186 insertions(+), 95 deletions(-)
 create mode 100644 spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/PropertyPathUtils.java

diff --git a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
index 363155be..92a675cb 100644
--- a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
+++ b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
@@ -37,6 +37,8 @@
 import lombok.Value;
 import lombok.With;
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
+
 /**
  * @author Myeonghyeon Lee
  */
@@ -57,6 +59,7 @@ public class Board {
 	@Builder.Default
 	private List<Post> posts = new ArrayList<>();
 
+	@SqlTableAlias("b_audit")
 	@Column("board_id")
 	private Audit audit;
 
diff --git a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
index 936efe81..0ee4c48d 100644
--- a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
+++ b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
@@ -28,6 +28,7 @@
 import lombok.Builder;
 import lombok.Value;
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
 import com.navercorp.spring.data.jdbc.plus.sql.guide.board.Board.Label;
 import com.navercorp.spring.data.jdbc.plus.sql.guide.board.Board.Post;
 
@@ -44,6 +45,7 @@ public class PostDto {
 	@Column
 	Post post;
 
+	@SqlTableAlias("p_labels")
 	@MappedCollection(idColumn = "board_id")
 	Set<Label> labels;
 }
diff --git a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.groovy b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.groovy
index 6928bacd..751b39d7 100644
--- a/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.groovy
+++ b/guide-projects/plus-sql-java-groovy-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.groovy
@@ -117,8 +117,8 @@ class BoardSql extends SqlGeneratorSupport {
         LEFT OUTER JOIN n_config AS post_configMap
         ON post_configMap.post_id = post.id
         
-        LEFT OUTER JOIN n_label AS labels
-        ON post.board_id = labels.board_id
+        LEFT OUTER JOIN n_label AS p_labels
+        ON post.board_id = p_labels.board_id
         
         WHERE post.id = :postId
         """
diff --git a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
index defabb37..30745b9c 100644
--- a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
+++ b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.java
@@ -36,6 +36,8 @@
 import lombok.Value;
 import lombok.With;
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
+
 /**
  * @author Myeonghyeon Lee
  */
@@ -56,6 +58,7 @@ public class Board {
 	@Builder.Default
 	private List<Post> posts = new ArrayList<>();
 
+	@SqlTableAlias("b_audit")
 	@Column("board_id")
 	private Audit audit;
 
diff --git a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
index aa0dc60c..2050e0f5 100644
--- a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
+++ b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.java
@@ -28,6 +28,8 @@
 import lombok.Builder;
 import lombok.Value;
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
+
 /**
  * @author Myeonghyeon Lee
  */
@@ -41,6 +43,7 @@ public class PostDto {
 	@Column
 	Board.Post post;
 
+	@SqlTableAlias("p_labels")
 	@MappedCollection(idColumn = "board_id")
 	Set<Board.Label> labels;
 }
diff --git a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
index 0661a69c..af85c4e6 100644
--- a/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
+++ b/guide-projects/plus-sql-java-kotlin-guide/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
@@ -66,8 +66,8 @@ class BoardSql : SqlGeneratorSupport() {
         LEFT OUTER JOIN n_config AS post_configMap
         ON post_configMap.post_id = post.id
         
-        LEFT OUTER JOIN n_label AS labels
-        ON post.board_id = labels.board_id
+        LEFT OUTER JOIN n_label AS p_labels
+        ON post.board_id = p_labels.board_id
         
         WHERE post.id = :postId
         """
diff --git a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.kt b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.kt
index 1b356a82..f5879967 100644
--- a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.kt
+++ b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/Board.kt
@@ -18,6 +18,7 @@
 
 package com.navercorp.spring.data.jdbc.plus.sql.guide.board
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias
 import org.springframework.data.annotation.Id
 import org.springframework.data.relational.core.mapping.Column
 import org.springframework.data.relational.core.mapping.Embedded
@@ -41,6 +42,7 @@ data class Board(
     @MappedCollection(idColumn = "board_id", keyColumn = "board_index")
     val posts: List<Post>,
 
+    @SqlTableAlias("b_audit")
     @Column("board_id")
     val audit: Audit?,
 
diff --git a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.kt b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.kt
index 06b4dc4a..6c2c12dc 100644
--- a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.kt
+++ b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/PostDto.kt
@@ -18,6 +18,7 @@
 
 package com.navercorp.spring.data.jdbc.plus.sql.guide.board
 
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias
 import org.springframework.data.annotation.Id
 import org.springframework.data.relational.core.mapping.Column
 import org.springframework.data.relational.core.mapping.MappedCollection
@@ -34,6 +35,7 @@ data class PostDto(
     @Column
     val post: Post,
 
+    @SqlTableAlias("p_labels")
     @MappedCollection(idColumn = "board_id")
     val labels: Set<Label>
 )
diff --git a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
index 0661a69c..af85c4e6 100644
--- a/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
+++ b/guide-projects/plus-sql-kotlin-guide/src/main/kotlin/com/navercorp/spring/data/jdbc/plus/sql/guide/board/sql/BoardSql.kt
@@ -66,8 +66,8 @@ class BoardSql : SqlGeneratorSupport() {
         LEFT OUTER JOIN n_config AS post_configMap
         ON post_configMap.post_id = post.id
         
-        LEFT OUTER JOIN n_label AS labels
-        ON post.board_id = labels.board_id
+        LEFT OUTER JOIN n_label AS p_labels
+        ON post.board_id = p_labels.board_id
         
         WHERE post.id = :postId
         """
diff --git a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/AggregateResultJdbcConverter.java b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/AggregateResultJdbcConverter.java
index 5c0a6564..49a0f9d7 100644
--- a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/AggregateResultJdbcConverter.java
+++ b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/AggregateResultJdbcConverter.java
@@ -471,13 +471,14 @@ private Identifier getRelationEntityIdentifier(
 		return Identifier.of(relationPath.getReverseColumnName(), id, Object.class);
 	}
 
-	private String getIdColumnAlias(PersistentPropertyPathExtension relationPath) {
-		return relationPath.extendBy(relationPath.getLeafEntity().getRequiredIdProperty())
-			.getColumnAlias().getReference(identifierProcessing);
+	protected String getIdColumnAlias(PersistentPropertyPathExtension relationPath) {
+		return PropertyPathUtils.getColumnAlias(
+			relationPath.extendBy(relationPath.getLeafEntity().getRequiredIdProperty())
+		).getReference(identifierProcessing);
 	}
 
-	private String getQualifierColumnAlias(PersistentPropertyPathExtension relationPath) {
-		return relationPath.getTableAlias().getReference(identifierProcessing)
+	protected String getQualifierColumnAlias(PersistentPropertyPathExtension relationPath) {
+		return PropertyPathUtils.getTableAlias(relationPath).getReference(identifierProcessing)
 			+ "_" + relationPath.getQualifierColumn().getReference(identifierProcessing);
 	}
 
diff --git a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcBackReferencePropertyValueProvider.java b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcBackReferencePropertyValueProvider.java
index aebbcb42..e2a8f54b 100644
--- a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcBackReferencePropertyValueProvider.java
+++ b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcBackReferencePropertyValueProvider.java
@@ -54,8 +54,10 @@ class JdbcBackReferencePropertyValueProvider implements PropertyValueProvider<Re
 
 	@Override
 	public <T> T getPropertyValue(RelationalPersistentProperty property) {
-		return (T)resultSet.getObject(basePath.extendBy(property)
-				.getReverseColumnNameAlias().getReference(identifierProcessing));
+		PersistentPropertyPathExtension path = basePath.extendBy(property);
+
+		return (T)resultSet.getObject(PropertyPathUtils.getReverseColumnAlias(path)
+			.getReference(identifierProcessing));
 	}
 
 	public JdbcBackReferencePropertyValueProvider extendBy(RelationalPersistentProperty property) {
diff --git a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcPropertyValueProvider.java b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcPropertyValueProvider.java
index e8aa8dad..f2aed3e0 100644
--- a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcPropertyValueProvider.java
+++ b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/JdbcPropertyValueProvider.java
@@ -68,7 +68,8 @@ public boolean hasProperty(RelationalPersistentProperty property) {
 	}
 
 	private String getColumnName(RelationalPersistentProperty property) {
-		return basePath.extendBy(property).getColumnAlias().getReference(identifierProcessing);
+		PersistentPropertyPathExtension path = basePath.extendBy(property);
+		return PropertyPathUtils.getColumnAlias(path).getReference(identifierProcessing);
 	}
 
 	public JdbcPropertyValueProvider extendBy(RelationalPersistentProperty property) {
diff --git a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/PropertyPathUtils.java b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/PropertyPathUtils.java
new file mode 100644
index 00000000..168d22d9
--- /dev/null
+++ b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/PropertyPathUtils.java
@@ -0,0 +1,96 @@
+package com.navercorp.spring.data.jdbc.plus.sql.convert;
+
+import javax.annotation.Nullable;
+
+import org.springframework.data.mapping.PersistentPropertyPath;
+import org.springframework.data.relational.core.mapping.PersistentPropertyPathExtension;
+import org.springframework.data.relational.core.mapping.RelationalPersistentProperty;
+import org.springframework.data.relational.core.sql.IdentifierProcessing;
+import org.springframework.data.relational.core.sql.SqlIdentifier;
+import org.springframework.util.Assert;
+
+import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
+
+public class PropertyPathUtils {
+	static SqlIdentifier getColumnAlias(PersistentPropertyPathExtension path) {
+		return getColumnAlias(path, path.getColumnName());
+	}
+
+	static SqlIdentifier getColumnAlias(PersistentPropertyPathExtension path, SqlIdentifier columnName) {
+		PersistentPropertyPathExtension tableOwner = getTableOwningAncestor(path);
+		if (tableOwner.getLength() == 0) {
+			return columnName;
+		} else {
+			SqlIdentifier tableAlias = getTableAliasFromTableOwner(tableOwner);
+			return tableAlias == null ? columnName
+				: columnName.transform(name -> tableAlias.getReference(IdentifierProcessing.NONE) + "_" + name);
+		}
+	}
+
+	static SqlIdentifier getReverseColumnAlias(PersistentPropertyPathExtension path) {
+		return getReverseColumnAlias(path, path.getReverseColumnName());
+	}
+
+	static SqlIdentifier getReverseColumnAlias(
+		PersistentPropertyPathExtension path, SqlIdentifier reverseColumnName
+	) {
+		SqlIdentifier tableAlias = getTableAlias(path);
+		return tableAlias == null ? reverseColumnName
+			: reverseColumnName.transform(name -> tableAlias.getReference(IdentifierProcessing.NONE) + "_" + name);
+	}
+
+	// Refer from PersistentPropertyPathExtension#getTableAlias
+	@Nullable
+	public static SqlIdentifier getTableAlias(PersistentPropertyPathExtension path) {
+		PersistentPropertyPathExtension tableOwner = getTableOwningAncestor(path);
+		return getTableAliasFromTableOwner(tableOwner);
+	}
+
+	@Nullable
+	private static SqlIdentifier getTableAliasFromTableOwner(PersistentPropertyPathExtension tableOwner) {
+		if (tableOwner.getLength() > 0) {	// path != null
+			return assembleTableAlias(tableOwner);
+		}
+
+		// path == null : root
+		SqlTableAlias sqlTableAlias = tableOwner.getLeafEntity().findAnnotation(SqlTableAlias.class);
+		if (sqlTableAlias != null) {
+			return SqlIdentifier.quoted(sqlTableAlias.value());
+		}
+
+		return null;
+	}
+
+	private static PersistentPropertyPathExtension getTableOwningAncestor(PersistentPropertyPathExtension path) {
+		return path.isEntity() && !path.isEmbedded() ? path : getTableOwningAncestor(path.getParentPath());
+	}
+
+	private static SqlIdentifier assembleTableAlias(PersistentPropertyPathExtension path) {
+
+		Assert.state(path != null, "Path is null");
+
+		PersistentPropertyPath<? extends RelationalPersistentProperty> propertyPath = path.getRequiredPersistentPropertyPath();
+		RelationalPersistentProperty leafProperty = propertyPath.getRequiredLeafProperty();
+
+		String prefix;
+		if (path.isEmbedded()) {
+			prefix = leafProperty.getEmbeddedPrefix();
+		} else {
+			SqlTableAlias sqlTableAlias = leafProperty.findPropertyOrOwnerAnnotation(SqlTableAlias.class);
+			prefix = sqlTableAlias != null
+				? sqlTableAlias.value()
+				: leafProperty.getName();
+		}
+
+		if (path.getLength() == 1) {
+			Assert.notNull(prefix, "Prefix mus not be null.");
+			return SqlIdentifier.quoted(prefix);
+		}
+
+		PersistentPropertyPathExtension parentPath = path.getParentPath();
+		SqlIdentifier sqlIdentifier = assembleTableAlias(parentPath);
+
+		return parentPath.isEmbedded() ? sqlIdentifier.transform(name -> name.concat(prefix))
+			: sqlIdentifier.transform(name -> name + "_" + prefix);
+	}
+}
diff --git a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlContext.java b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlContext.java
index f195e8a4..d0b95c8c 100644
--- a/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlContext.java
+++ b/spring-data-jdbc-plus-sql/src/main/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlContext.java
@@ -15,18 +15,11 @@
  */
 package com.navercorp.spring.data.jdbc.plus.sql.convert;
 
-import javax.annotation.Nullable;
-
-import org.springframework.data.mapping.PersistentPropertyPath;
 import org.springframework.data.relational.core.mapping.PersistentPropertyPathExtension;
 import org.springframework.data.relational.core.mapping.RelationalPersistentEntity;
-import org.springframework.data.relational.core.mapping.RelationalPersistentProperty;
 import org.springframework.data.relational.core.sql.Column;
 import org.springframework.data.relational.core.sql.SqlIdentifier;
 import org.springframework.data.relational.core.sql.Table;
-import org.springframework.util.Assert;
-
-import com.navercorp.spring.data.jdbc.plus.sql.annotation.SqlTableAlias;
 
 /**
  * Utility to get from path to SQL DSL elements.
@@ -67,66 +60,22 @@ public Table getTable() {
 
 	@Override
 	public Table getTable(PersistentPropertyPathExtension path) {
-		SqlIdentifier tableAlias = this.getTableAlias(path);
+		SqlIdentifier tableAlias = PropertyPathUtils.getTableAlias(path);
 		Table table = Table.create(path.getTableName());
 		return tableAlias == null ? table : table.as(tableAlias);
 	}
 
 	@Override
 	public Column getColumn(PersistentPropertyPathExtension path) {
-		return getTable(path).column(path.getColumnName()).as(path.getColumnAlias());
+		SqlIdentifier columnName = path.getColumnName();
+		SqlIdentifier columnAlias = PropertyPathUtils.getColumnAlias(path, columnName);
+		return getTable(path).column(columnName).as(columnAlias);
 	}
 
 	@Override
 	public Column getReverseColumn(PersistentPropertyPathExtension path) {
-		return getTable(path).column(path.getReverseColumnName()).as(path.getReverseColumnNameAlias());
-	}
-
-	// Refer from PersistentPropertyPathExtension#getTableAlias
-	@Nullable
-	private SqlIdentifier getTableAlias(PersistentPropertyPathExtension path) {
-		PersistentPropertyPathExtension tableOwner = getTableOwningAncestor(path);
-		if (tableOwner.getLength() > 0) {	// path != null
-			return this.assembleTableAlias(tableOwner);
-		}
-
-		// path == null : root
-		SqlTableAlias sqlTableAlias = tableOwner.getLeafEntity().findAnnotation(SqlTableAlias.class);
-		if (sqlTableAlias != null) {
-			return this.table.as(sqlTableAlias.value()).getReferenceName();
-		}
-
-		return null;
-	}
-
-	private PersistentPropertyPathExtension getTableOwningAncestor(PersistentPropertyPathExtension path) {
-		return path.isEntity() && !path.isEmbedded() ? path : this.getTableOwningAncestor(path.getParentPath());
-	}
-
-	private SqlIdentifier assembleTableAlias(PersistentPropertyPathExtension path) {
-
-		Assert.state(path != null, "Path is null");
-
-		PersistentPropertyPath<? extends RelationalPersistentProperty> propertyPath = path.getRequiredPersistentPropertyPath();
-		RelationalPersistentProperty leafProperty = propertyPath.getRequiredLeafProperty();
-
-		String prefix;
-		if (path.isEmbedded()) {
-			prefix = leafProperty.getEmbeddedPrefix();
-		} else {
-			SqlTableAlias sqlTableAlias = leafProperty.findPropertyOrOwnerAnnotation(SqlTableAlias.class);
-			prefix = sqlTableAlias != null ? sqlTableAlias.value() : leafProperty.getName();
-		}
-
-		if (path.getLength() == 1) {
-			Assert.notNull(prefix, "Prefix mus not be null.");
-			return SqlIdentifier.quoted(prefix);
-		}
-
-		PersistentPropertyPathExtension parentPath = path.getParentPath();
-		SqlIdentifier sqlIdentifier = this.assembleTableAlias(parentPath);
-
-		return parentPath.isEmbedded() ? sqlIdentifier.transform(name -> name.concat(prefix))
-			: sqlIdentifier.transform(name -> name + "_" + prefix);
+		SqlIdentifier reverseColumnName = path.getReverseColumnName();
+		SqlIdentifier reverseColumnAlias = PropertyPathUtils.getReverseColumnAlias(path, reverseColumnName);
+		return getTable(path).column(reverseColumnName).as(reverseColumnAlias);
 	}
 }
diff --git a/spring-data-jdbc-plus-sql/src/test/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlProviderTest.java b/spring-data-jdbc-plus-sql/src/test/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlProviderTest.java
index b440c362..a4cea721 100644
--- a/spring-data-jdbc-plus-sql/src/test/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlProviderTest.java
+++ b/spring-data-jdbc-plus-sql/src/test/java/com/navercorp/spring/data/jdbc/plus/sql/convert/SqlProviderTest.java
@@ -22,8 +22,10 @@
 
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
+import org.springframework.data.annotation.Id;
 import org.springframework.data.jdbc.core.convert.BasicJdbcConverter;
 import org.springframework.data.jdbc.core.convert.JdbcConverter;
+import org.springframework.data.relational.core.dialect.MySqlDialect;
 import org.springframework.data.relational.core.mapping.Column;
 import org.springframework.data.relational.core.mapping.Embedded;
 import org.springframework.data.relational.core.mapping.NamingStrategy;
@@ -74,10 +76,10 @@ void columnsWithEmbeddedAndAlias() {
 		// then
 		assertThat(columns).contains(
 			"ts.tester_id AS tester_id, "
-			+ "address.tester_outer_id AS testInner_tester_outer_id, "
+			+ "address.tester_outer_id AS address_tester_outer_id, "
 			+ "ts.tester_nm AS tester_nm, "
-			+ "address.cty AS testInner_cty, "
-			+ "address.state AS testInner_state, "
+			+ "address.cty AS address_cty, "
+			+ "address.state AS address_state, "
 			+ "ts.adr_cty AS adr_cty, "
 			+ "ts.adr_state AS adr_state"
 		);
@@ -100,19 +102,19 @@ void columnsWithNoRootTableAlias() {
 		assertThat(columns).contains(
 			"test_entity_no_root_table_alias.root_id AS root_id, "
 				+ "test_entity_no_root_table_alias.root_name AS root_name, "
-				+ "tOuter.test_root_id AS testOuter_test_root_id, "
-				+ "tOuter.tester_id AS testOuter_tester_id, "
-				+ "tOuter_address.tester_outer_id AS testOuter_testInner_tester_outer_id, "
-				+ "tOuter.tester_nm AS testOuter_tester_nm, "
+				+ "tOuter.test_root_id AS tOuter_test_root_id, "
+				+ "tOuter.tester_id AS tOuter_tester_id, "
+				+ "tOuter_address.tester_outer_id AS tOuter_address_tester_outer_id, "
+				+ "tOuter.tester_nm AS tOuter_tester_nm, "
 				+ "test_entity_no_root_table_alias.outer_tester_id AS outer_tester_id, "
-				+ "outer_address.tester_outer_id AS outer_testInner_tester_outer_id, "
+				+ "outer_address.tester_outer_id AS outer_address_tester_outer_id, "
 				+ "test_entity_no_root_table_alias.outer_tester_nm AS outer_tester_nm, "
-				+ "tOuter_address.cty AS testOuter_testInner_cty, "
-				+ "tOuter_address.state AS testOuter_testInner_state, "
-				+ "tOuter.adr_cty AS testOuter_adr_cty, "
-				+ "tOuter.adr_state AS testOuter_adr_state, "
-				+ "outer_address.cty AS outer_testInner_cty, "
-				+ "outer_address.state AS outer_testInner_state, "
+				+ "tOuter_address.cty AS tOuter_address_cty, "
+				+ "tOuter_address.state AS tOuter_address_state, "
+				+ "tOuter.adr_cty AS tOuter_adr_cty, "
+				+ "tOuter.adr_state AS tOuter_adr_state, "
+				+ "outer_address.cty AS outer_address_cty, "
+				+ "outer_address.state AS outer_address_state, "
 				+ "test_entity_no_root_table_alias.outer_adr_cty AS outer_adr_cty, "
 				+ "test_entity_no_root_table_alias.outer_adr_state AS outer_adr_state"
 		);
@@ -140,17 +142,17 @@ void columnsEmbeddedNestedTableAlias() {
 				+ "teie.tester_id AS tester_id, "
 				+ "teie.tester_nm AS tester_nm, "
 				+ "testOuter.tester_id AS testOuter_tester_id, "
-				+ "testOuter_address.tester_outer_id AS testOuter_testInner_tester_outer_id, "
+				+ "testOuter_address.tester_outer_id AS testOuter_address_tester_outer_id, "
 				+ "testOuter.tester_nm AS testOuter_tester_nm, "
 				+ "teie.outer_tester_id AS outer_tester_id, "
-				+ "outer_address.tester_outer_id AS outer_testInner_tester_outer_id, "
+				+ "outer_address.tester_outer_id AS outer_address_tester_outer_id, "
 				+ "teie.outer_tester_nm AS outer_tester_nm, "
-				+ "testOuter_address.cty AS testOuter_testInner_cty, "
-				+ "testOuter_address.state AS testOuter_testInner_state, "
+				+ "testOuter_address.cty AS testOuter_address_cty, "
+				+ "testOuter_address.state AS testOuter_address_state, "
 				+ "testOuter.adr_cty AS testOuter_adr_cty, "
 				+ "testOuter.adr_state AS testOuter_adr_state, "
-				+ "outer_address.cty AS outer_testInner_cty, "
-				+ "outer_address.state AS outer_testInner_state, "
+				+ "outer_address.cty AS outer_address_cty, "
+				+ "outer_address.state AS outer_address_state, "
 				+ "teie.outer_adr_cty AS outer_adr_cty, "
 				+ "teie.outer_adr_state AS outer_adr_state"
 		);
@@ -193,14 +195,38 @@ void namingStrategyForNonColumnAnnotatedField() {
 		// then
 		assertThat(columns).contains(
 			"ts.x_tester_id AS x_tester_id, "
-				+ "address.tester_outer_id AS testInner_tester_outer_id, "
+				+ "address.tester_outer_id AS address_tester_outer_id, "
 				+ "ts.tester_nm AS tester_nm, "
-				+ "address.cty AS testInner_cty, "
-				+ "address.x_state AS testInner_x_state, "
+				+ "address.cty AS address_cty, "
+				+ "address.x_state AS address_x_state, "
 				+ "ts.adr_cty AS adr_cty, "
 				+ "ts.adr_x_state AS adr_x_state");
 	}
 
+	@Test
+	@DisplayName("@SqlTableAlias 와 Quoting 확인")
+	void quotingWithTableAlias() {
+		// given
+		RelationalMappingContext context = new RelationalMappingContext(new PrefixingNamingStrategy());
+		JdbcConverter converter = new BasicJdbcConverter(context, (identifier, path) -> {
+			throw new UnsupportedOperationException();
+		});
+		SqlProvider sut = new SqlProvider(context, converter, MySqlDialect.INSTANCE);
+
+		// when
+		String columns = sut.columns(TestOuterEntity.class);
+
+		// then
+		assertThat(columns).contains(
+			"`ts`.`x_tester_id` AS `x_tester_id`, "
+				+ "`address`.`tester_outer_id` AS `address_tester_outer_id`, "
+				+ "`ts`.`tester_nm` AS `tester_nm`, "
+				+ "`address`.`cty` AS `address_cty`, "
+				+ "`address`.`x_state` AS `address_x_state`, "
+				+ "`ts`.`adr_cty` AS `adr_cty`, "
+				+ "`ts`.`adr_x_state` AS `adr_x_state`");
+	}
+
 	@SqlTableAlias("ts")
 	static class TestOuterEntity {
 		private Long testerId;
@@ -253,6 +279,7 @@ static class TestEntityNoRootTableAlias {
 
 	@Table("teie")
 	static class TestEmbeddedNested {
+		@Id
 		private Long rootId;
 
 		@Column("root_name")