diff options
Diffstat (limited to 'docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations')
| -rw-r--r-- | docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/DatabaseMigrator.cs | 4 | ||||
| -rw-r--r-- | docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/Migrations/SqliteDatabaseMigrator.cs | 11 | 
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)              { | 
