Fixed type mapping for database handling.
This commit is contained in:
@ -79,7 +79,8 @@ namespace HermesSocketServer.Store.Internal
|
|||||||
ImmutableList<V>? list = null;
|
ImmutableList<V>? list = null;
|
||||||
lock (_lock)
|
lock (_lock)
|
||||||
{
|
{
|
||||||
if (!keys.Any() || !values.Any()) {
|
if (!keys.Any() || !values.Any())
|
||||||
|
{
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -95,15 +95,14 @@ namespace HermesSocketServer.Store.Internal
|
|||||||
|
|
||||||
var ctp = columns.ToDictionary(c => c, c => _columnPropertyRelations[c]);
|
var ctp = columns.ToDictionary(c => c, c => _columnPropertyRelations[c]);
|
||||||
var sb = new StringBuilder();
|
var sb = new StringBuilder();
|
||||||
var columnsLower = columns.Select(c => c.ToLower());
|
|
||||||
sb.Append($"INSERT INTO \"{table}\" (\"{string.Join("\", \"", columns)}\") VALUES ");
|
sb.Append($"INSERT INTO \"{table}\" (\"{string.Join("\", \"", columns)}\") VALUES ");
|
||||||
for (var row = 0; row < rows; row++)
|
for (var row = 0; row < rows; row++)
|
||||||
{
|
{
|
||||||
sb.Append("(");
|
sb.Append("(");
|
||||||
foreach (var column in columnsLower)
|
foreach (var column in columns)
|
||||||
{
|
{
|
||||||
sb.Append('@')
|
sb.Append('@')
|
||||||
.Append(column)
|
.Append(column.ToLower())
|
||||||
.Append(row);
|
.Append(row);
|
||||||
|
|
||||||
if (typeMapping.TryGetValue(column, out var type))
|
if (typeMapping.TryGetValue(column, out var type))
|
||||||
|
Reference in New Issue
Block a user