Implement InsertAsync with stored procedure in CatalogRepository

Replaced the InsertAsync placeholder with a full implementation that inserts a new VwmyCatalog using the dbo.PRTBMY_CATALOG_INSERT stored procedure. The method sets up SQL parameters, handles the output GUID, and retrieves the inserted catalog from the view. Exceptions are thrown if the insert fails or the catalog cannot be loaded.
This commit is contained in:
OlgunR
2026-01-16 11:42:38 +01:00
parent f1cecf117a
commit ab1f73f987

View File

@@ -27,9 +27,33 @@ public class CatalogRepository : ICatalogRepository
public async Task<VwmyCatalog> InsertAsync(VwmyCatalog catalog, CancellationToken cancellationToken = default) public async Task<VwmyCatalog> InsertAsync(VwmyCatalog catalog, CancellationToken cancellationToken = default)
{ {
// Platzhalter: Insert-Prozedur folgt. var guidParam = new SqlParameter("@GUID", SqlDbType.Int)
// TODO: Replace with dedicated insert stored procedure invocation. {
throw new NotImplementedException("Insert stored procedure not implemented yet."); Direction = ParameterDirection.Output
};
var catTitleParam = new SqlParameter("@CAT_TITLE", catalog.CatTitle);
var catStringParam = new SqlParameter("@CAT_STRING", catalog.CatString);
var addedWhoParam = new SqlParameter("@ADDED_WHO", (object?)catalog.AddedWho ?? DBNull.Value);
await _db.Database.ExecuteSqlRawAsync(
"EXEC dbo.PRTBMY_CATALOG_INSERT @CAT_TITLE, @CAT_STRING, @ADDED_WHO, @GUID OUTPUT",
parameters: new[] { catTitleParam, catStringParam, addedWhoParam, guidParam },
cancellationToken: cancellationToken);
if (guidParam.Value == DBNull.Value)
{
throw new InvalidOperationException("Failed to insert catalog via stored procedure.");
}
var guid = (int)guidParam.Value;
var created = await _db.VwmyCatalogs.AsNoTracking().FirstOrDefaultAsync(x => x.Guid == guid, cancellationToken);
if (created == null)
{
throw new InvalidOperationException("Inserted catalog could not be loaded from view.");
}
return created;
} }
public async Task<VwmyCatalog?> UpdateAsync(int id, VwmyCatalog catalog, CancellationToken cancellationToken = default) public async Task<VwmyCatalog?> UpdateAsync(int id, VwmyCatalog catalog, CancellationToken cancellationToken = default)