weiai/FreeSql
1
0
Fork 0
mirror of https://github.com/dotnetcore/FreeSql.git synced 2026-02-12 03:10:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 修复 Duckdb CodeFirst Create Index异常

Browse Source
This commit is contained in:
d4ilys
2025-05-13 11:02:55 +08:00
parent 17e02bb315
commit 62f7be2910
2 changed files with 21 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
FreeSql.Tests/FreeSql.Tests.Provider.Duckdb/g.cs
View File

@@ -14,7 +14,7 @@ public class g
.UseNameConvert(FreeSql.Internal.NameConvertType.ToLower)
.UseMonitorCommand(
cmd => Trace.WriteLine("\r\n线程" + Thread.CurrentThread.ManagedThreadId + ": " + cmd.CommandText) //监听SQL命令对象，在执行前
//, (cmd, traceLog) => Console.WriteLine(traceLog)
, (cmd, traceLog) => Console.WriteLine(traceLog)
)
.Build();
});

37
Providers/FreeSql.Provider.Duckdb/DuckdbCodeFirst.cs
View File

@@ -167,32 +167,35 @@ namespace FreeSql.Duckdb
}
sb.Remove(sb.Length - 1, 1);
sb.Append("\r\n) \r\n;\r\n");
////创建表的索引
//foreach (var uk in tb.Indexes)
//{
// sb.Append("CREATE ");
// if (uk.IsUnique) sb.Append("UNIQUE ");
// sb.Append("INDEX ");
// sb.Append(_commonUtils.QuoteSqlName(tbname[0], ReplaceIndexName(uk.Name, tbname[1]))).Append(" ON ").Append(tbname[1]).Append("(");
// foreach (var tbcol in uk.Columns)
// {
// sb.Append(_commonUtils.QuoteSqlName(tbcol.Column.Attribute.Name));
// if (tbcol.IsDesc) sb.Append(" DESC");
// sb.Append(", ");
// }
// sb.Remove(sb.Length - 2, 2).Append(");\r\n");
//}
//创建表的索引
foreach (var uk in tb.Indexes)
{
sb.Append("CREATE ");
if (uk.IsUnique) sb.Append("UNIQUE ");
sb.Append("INDEX ").Append(_commonUtils.QuoteSqlName(tbname[0], ReplaceIndexName(uk.Name, tbname[1]))).Append(" ON ").Append(tbname[1]).Append("(");
foreach (var tbcol in uk.Columns)
{
sb.Append(_commonUtils.QuoteSqlName(tbcol.Column.Attribute.Name));
if (tbcol.IsDesc) sb.Append(" DESC");
sb.Append(", ");
}
sb.Remove(sb.Length - 2, 2).Append(");\r\n");
}
//创建表的索引
foreach (var uk in tb.Indexes)
{
sb.Append("CREATE ");
if (uk.IsUnique) sb.Append("UNIQUE ");
if (uk.IsUnique)
sb.Append("UNIQUE ");
sb.Append("INDEX ");
sb.Append(_commonUtils.QuoteSqlName(ReplaceIndexName(uk.Name, tbname[1]))).Append(" ON ").Append(createTableName);
sb.Append(uk.Name).Append(" ON ").Append(_commonUtils.QuoteSqlName(ReplaceIndexName(createTableName, tbname[1])));
sb.Append("(");
foreach (var tbcol in uk.Columns)
{
sb.Append(_commonUtils.QuoteSqlName(tbcol.Column.Attribute.Name));
if (tbcol.IsDesc) sb.Append(" DESC");
if (tbcol.IsDesc)
sb.Append(" DESC");
sb.Append(", ");
}
sb.Remove(sb.Length - 2, 2).Append(");\r\n");