Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Fylum.Migrations.Api/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public static void Main(string[] args)
{
options.HostName = builder.Configuration["POSTGRES_HOST"]!;
options.Port = int.Parse(builder.Configuration["POSTGRES_PORT"]!);
options.DatabaseName = builder.Configuration["POSTGRES_DATABASE"]!;
options.DatabaseName = builder.Configuration["POSTGRES_DATABASENAME"]!;
options.Username = builder.Configuration["POSTGRES_USERNAME"]!;
options.Password = builder.Configuration["POSTGRES_PASSWORD"]!;
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ private void InsertMigration(ProvidedMigration migration)
id = migration.Id,
name = migration.Name
};
string sql = @$"INSERT INTO migrations
string sql = @$"INSERT INTO migration.migrations
(id, name)
VALUES (@{nameof(param.id)}, @{nameof(param.name)})";
var transaction = _transactionFactory.GetTransaction();
Expand All @@ -45,7 +45,7 @@ private void InsertPerformedMigration(PerformedMigration performedMigration)
timestamp = performedMigration.Timestamp,
migrationId = performedMigration.Migration.Id
};
string sql = @$"INSERT INTO migrations_performed
string sql = @$"INSERT INTO migration.migrations_performed
(id, time_stamp, migration_id)
VALUES (@{nameof(param.id)}, @{nameof(param.timestamp)}, @{nameof(param.migrationId)})";
var transaction = _transactionFactory.GetTransaction();
Expand Down Expand Up @@ -87,8 +87,8 @@ private IEnumerable<PerformedMigrationQueryModel> QueryPerformedMigrations()
mp.time_stamp AS {nameof(PerformedMigrationQueryModel.Timestamp)},
mp.migration_id AS {nameof(PerformedMigrationQueryModel.MigrationId)},
m.name AS {nameof(PerformedMigrationQueryModel.MigratioName)}
FROM migrations_performed mp
JOIN migrations m
FROM migration.migrations_performed mp
JOIN migration.migrations m
ON mp.migration_id = m.id
ORDER BY mp.time_stamp DESC;";
var transaction = _transactionFactory.GetTransaction();
Expand All @@ -103,8 +103,8 @@ JOIN migrations m
mp.time_stamp AS {nameof(PerformedMigrationQueryModel.Timestamp)},
mp.migration_id AS {nameof(PerformedMigrationQueryModel.MigrationId)},
m.name AS {nameof(PerformedMigrationQueryModel.MigratioName)}
FROM migrations_performed mp
JOIN migrations m
FROM migration.migrations_performed mp
JOIN migration.migrations m
ON mp.migration_id = m.id
WHERE m.id = @{nameof(param.id)};";
var transaction = _transactionFactory.GetTransaction();
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
CREATE SCHEMA migration;
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
CREATE TABLE migrations
CREATE TABLE migration.migrations
(
id uuid NOT NULL,
name text NOT NULL,
Expand Down
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
CREATE TABLE migrations_performed
CREATE TABLE migration.migrations_performed
(
id uuid NOT NULL,
time_stamp timestamp with time zone NOT NULL,
migration_id uuid NOT NULL,
PRIMARY KEY (id),
CONSTRAINT fk_migrations FOREIGN KEY (migration_id)
REFERENCES migrations (id) MATCH SIMPLE
REFERENCES migration.migrations (id) MATCH SIMPLE
ON UPDATE NO ACTION
ON DELETE NO ACTION
NOT VALID
Expand Down
2 changes: 1 addition & 1 deletion Fylum.Migrations.Provider/Migrations/0_Migrations.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,14 @@ internal class MigrationsMigration : MigrationFromEmbeddedResources
public override Guid Id => Guid.Parse("d8d4a2b4-edc7-4b40-a618-f196bf3eb633");
public override string Name => "0_Migrations";


protected override IEnumerable<string> ResourceFolderNameParts
=> ["MigrationFiles", "0_Migrations"];

protected override IEnumerable<string> ResourceNames
{
get
{
yield return "migration_schema.psql";
yield return "migrations.psql";
yield return "migrations_performed.psql";
}
Expand Down