aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs4
-rw-r--r--docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs11
2 files changed, 6 insertions, 9 deletions
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs
index e5ef05d..cf10916 100644
--- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs
+++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs
@@ -6,8 +6,8 @@ public class TableColumn
{
public TableColumn(string name, string type, bool notNull, int primaryKey)
{
- Name = name.ToLowerInvariant();
- Type = type.ToLowerInvariant();
+ Name = name;
+ Type = type;
NotNull = notNull;
PrimaryKey = primaryKey;
}
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs
index 83b360b..536d8d6 100644
--- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs
+++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs
@@ -72,7 +72,7 @@ public class SqliteDatabaseMigrator : IDatabaseMigrator
CheckTableName(tableName);
var count = dbConnection.QuerySingle<int>(
- "SELECT count(*) FROM sqlite_schema WHERE type = 'table' AND tbl_name = @TableName;",
+ "SELECT count(*) FROM sqlite_schema WHERE type = 'table' AND name = @TableName;",
new { TableName = tableName });
if (count == 0)
{
@@ -84,7 +84,6 @@ public class SqliteDatabaseMigrator : IDatabaseMigrator
}
else
{
-
var table = new Table(tableName);
var queryColumns = dbConnection.Query<dynamic>($"PRAGMA table_info({tableName})");
@@ -137,13 +136,11 @@ public class SqliteDatabaseMigrator : IDatabaseMigrator
{
CheckTableName(tableName);
- var columnSql = string.Join(",\n", columns.Select(GenerateCreateTableColumnSqlSegment));
-
var sql = $@"
CREATE TABLE {tableName} (
- {columnSql}
+ {string.Join(",\n ", columns.Select(GenerateCreateTableColumnSqlSegment))}
);
- ";
+ ".Trim();
return sql;
@@ -160,7 +157,7 @@ CREATE TABLE {tableName} (
var notChangeColumns = wantedTableColumnNames.Where(column => databaseTableColumnNames.Contains(column)).ToList();
var addColumns = wantedTableColumnNames.Where(column => !databaseTableColumnNames.Contains(column)).ToList();
- if (databaseTable is not null && dbConnection.Query<int>($"SELECT count(*) FROM {tableName}").Single() > 0)
+ if (databaseTable is not null && dbConnection.QuerySingle<int>($"SELECT count(*) FROM {tableName}") > 0)
{
foreach (var columnName in addColumns)
{