Skip to content

Commit 292c009

Browse files
committed
modify aliases
1 parent 49afe72 commit 292c009

2 files changed

Lines changed: 4 additions & 8 deletions

File tree

QueryBuilder.Tests/OracleLegacyLimitTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public void WithNoLimit()
5656
compiler.ApplyLegacyLimit(ctx);
5757

5858
// Assert:
59-
Assert.Matches($"SELECT \\* FROM \\(SELECT \"(SqlKata_.*__)\"\\.\\*, ROWNUM \"(SqlKata_.*__)\" FROM \\({SqlPlaceholder}\\) \"(SqlKata_.*__)\"\\) WHERE \"(SqlKata_.*__)\" > \\?", ctx.RawSql);
59+
Assert.Equal("SELECT * FROM (SELECT \"results_wrapper\".*, ROWNUM \"row_num\" FROM (GENERATED_SQL) \"results_wrapper\") WHERE \"row_num\" > ?", ctx.RawSql);
6060
Assert.Equal(20, ctx.Bindings[0]);
6161
Assert.Single(ctx.Bindings);
6262
}
@@ -72,7 +72,7 @@ public void WithLimitAndOffset()
7272
compiler.ApplyLegacyLimit(ctx);
7373

7474
// Assert:
75-
Assert.Matches($"SELECT \\* FROM \\(SELECT \"(SqlKata_.*__)\"\\.\\*, ROWNUM \"(SqlKata_.*__)\" FROM \\({SqlPlaceholder}\\) \"(SqlKata_.*__)\" WHERE ROWNUM <= \\?\\) WHERE \"(SqlKata_.*__)\" > \\?", ctx.RawSql);
75+
Assert.Equal("SELECT * FROM (SELECT \"results_wrapper\".*, ROWNUM \"row_num\" FROM (GENERATED_SQL) \"results_wrapper\" WHERE ROWNUM <= ?) WHERE \"row_num\" > ?", ctx.RawSql);
7676
Assert.Equal(25, ctx.Bindings[0]);
7777
Assert.Equal(20, ctx.Bindings[1]);
7878
Assert.Equal(2, ctx.Bindings.Count);

QueryBuilder/Compilers/OracleCompiler.cs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -74,14 +74,10 @@ internal void ApplyLegacyLimit(SqlResult ctx)
7474
return;
7575
}
7676

77-
//@todo replace with alias generator
78-
var alias1 = WrapValue("SqlKata_A__");
79-
var alias2 = WrapValue("SqlKata_B__");
80-
8177
string newSql;
8278
if (limit == 0)
8379
{
84-
newSql = $"SELECT * FROM (SELECT {alias1}.*, ROWNUM {alias2} FROM ({ctx.RawSql}) {alias1}) WHERE {alias2} > ?";
80+
newSql = $"SELECT * FROM (SELECT \"results_wrapper\".*, ROWNUM \"row_num\" FROM ({ctx.RawSql}) \"results_wrapper\") WHERE \"row_num\" > ?";
8581
ctx.Bindings.Add(offset);
8682
}
8783
else if (offset == 0)
@@ -91,7 +87,7 @@ internal void ApplyLegacyLimit(SqlResult ctx)
9187
}
9288
else
9389
{
94-
newSql = $"SELECT * FROM (SELECT {alias1}.*, ROWNUM {alias2} FROM ({ctx.RawSql}) {alias1} WHERE ROWNUM <= ?) WHERE {alias2} > ?";
90+
newSql = $"SELECT * FROM (SELECT \"results_wrapper\".*, ROWNUM \"row_num\" FROM ({ctx.RawSql}) \"results_wrapper\" WHERE ROWNUM <= ?) WHERE \"row_num\" > ?";
9591
ctx.Bindings.Add(limit + offset);
9692
ctx.Bindings.Add(offset);
9793
}

0 commit comments

Comments
 (0)