Adding database configuration #1

Merged
csimonapastore merged 8 commits from connections into main 2025-02-21 18:42:34 +01:00
2 changed files with 21 additions and 23 deletions
Showing only changes of commit b26c553d12 - Show all commits

View File

@@ -39,6 +39,7 @@ internal static class Program
AppSettings appSettings = ProgramUtils.AddConfiguration(ref builder); AppSettings appSettings = ProgramUtils.AddConfiguration(ref builder);
ProgramUtils.AddServices(ref builder); ProgramUtils.AddServices(ref builder);
ProgramUtils.AddScopes(ref builder);
ProgramUtils.AddOpenApi(ref builder, appSettings); ProgramUtils.AddOpenApi(ref builder, appSettings);
ProgramUtils.AddDbContext(ref builder, appSettings); ProgramUtils.AddDbContext(ref builder, appSettings);
WebApplication app = builder.Build(); WebApplication app = builder.Build();

View File

@@ -130,42 +130,39 @@ public static class ProgramUtils
public static void AddDbContext(ref WebApplicationBuilder builder, AppSettings appSettings) public static void AddDbContext(ref WebApplicationBuilder builder, AppSettings appSettings)
{ {
Logger.Info("[ProgramUtils][AddDbContext] Adding DbContext"); Logger.Info("[ProgramUtils][AddDbContext] Adding DbContext");
var databaseAdded = ""; var messages = String.Empty;
if (!String.IsNullOrEmpty(appSettings.DatabaseSettings?.SqlServerConnectionString))
var connectionString = appSettings?.DatabaseSettings?.SqlServerConnectionString ?? String.Empty;
if (!String.IsNullOrEmpty(connectionString))
{ {
var connectionString = appSettings.DatabaseSettings?.SqlServerConnectionString ?? String.Empty;
connectionString = connectionString.Replace("SQLSERVER_DB_SERVER", Environment.GetEnvironmentVariable("SQLSERVER_DB_SERVER")); connectionString = connectionString.Replace("SQLSERVER_DB_SERVER", Environment.GetEnvironmentVariable("SQLSERVER_DB_SERVER"));
builder.Services.AddDbContext<SqlServerContext>(options => builder.Services.AddDbContext<SqlServerContext>(options =>
options.UseSqlServer(connectionString)); options.UseSqlServer(connectionString)
);
databaseAdded += "SqlServer"; messages = "SqlServerContext";
} }
connectionString = appSettings?.DatabaseSettings?.MongoDbConnectionString ?? String.Empty; if (!String.IsNullOrEmpty(appSettings.DatabaseSettings?.MongoDbConnectionString))
if (!String.IsNullOrEmpty(connectionString))
{ {
var connectionString = appSettings.DatabaseSettings?.MongoDbConnectionString ?? String.Empty;
connectionString = connectionString.Replace("MONGO_DB_SERVER", Environment.GetEnvironmentVariable("MONGODB_DB_SERVER")); connectionString = connectionString.Replace("MONGO_DB_SERVER", Environment.GetEnvironmentVariable("MONGODB_DB_SERVER"));
var mongoClient = new MongoClient(connectionString);
var databaseName = connectionString.Split("/").LastOrDefault(); var databaseName = connectionString.Split("/").LastOrDefault();
if (!String.IsNullOrEmpty(databaseName)) if (!String.IsNullOrEmpty(databaseName))
{ {
var dbContextOptions = new DbContextOptionsBuilder<MongoDbContext>() var client = new MongoClient(connectionString);
.UseMongoDB(mongoClient, databaseName); builder.Services.AddDbContext<MongoDbContext>(options =>
options.UseMongoDB(client, databaseName)
);
messages = messages + (String.IsNullOrEmpty(messages) ? "" : ", ") + "MongoDbContext";
}
}
messages = String.IsNullOrEmpty(messages) ? "No context" : messages;
Logger.Info($"[ProgramUtils][AddDbContext] {messages} added");
} }
databaseAdded += (String.IsNullOrEmpty(databaseAdded) ? "" : ", ") + "MongoDB"; public static void AddScopes(ref WebApplicationBuilder builder)
} {
Logger.Info("[ProgramUtils][AddScopes] Adding scopes");
var message = String.IsNullOrEmpty(databaseAdded) ? "No DbContext added" : $"{databaseAdded} added"; Logger.Info("[ProgramUtils][AddScopes] Done scopes");
Logger.Info($"[ProgramUtils][AddDbContext] {message}");
} }
} }