Egalware/Mapo-IOB-WIN
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Nuget SqlDB:

Browse Source 
- aggiunta metodi + fix x rilascio nuova vers
This commit is contained in:
Samuele Locatelli
2023-03-15 12:15:45 +01:00
parent 4dc7d6307f
commit 2df6c3ce72
3 changed files with 69 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
EgwProxy.SqlDb.Test/Program.cs
+3 -3
View File
@@ -149,14 +149,14 @@ namespace EgwProxy.SqlDb.Test
sb.AppendLine($"Aggiunto PODL{podl:0000000}");
}
// chiamo procedura insert PODL
bool fatto = dbClient.PodlWriteReq(CurrPodlReq);
bool fatto = dbClient.MesPodlWriteReq(CurrPodlReq);
sb.AppendLine($"Records Aggiunti!");
sb.AppendLine(separator);
break;
case stepType.DbMigrateAndSync:
try
{
var esitoMigrate = dbClient.forceMigrate();
var esitoMigrate = dbClient.DbForceMigrate();
sb.Append($"Migration: {esitoMigrate}");
}
catch (Exception exc)
@@ -285,7 +285,7 @@ namespace EgwProxy.SqlDb.Test
private static void serverTest(DbController dbClient)
{
Console.WriteLine(separator);
string testServer = dbClient.serverOk();
string testServer = dbClient.ServerOk();
Console.WriteLine($"Test connessione: esito {testServer}");
Console.WriteLine(separator);
Console.WriteLine();
EgwProxy.SqlDb/Controllers/DbController.cs
+63 -27
View File
@@ -45,15 +45,22 @@ namespace EgwProxy.SqlDb.Controllers
}
/// <summary>
/// Dispose classe
/// Recupera la tab di ActType corrente
/// </summary>
public void Dispose()
/// <returns></returns>
public List<ActTypeModel> ActTypeGetAll()
{
// Clear database context
connString = "";
List<ActTypeModel> dbResult = new List<ActTypeModel>();
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.DbSetActListType
.ToList();
}
return dbResult;
}
public bool forceMigrate()
public bool DbForceMigrate()
{
bool fatto = false;
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
@@ -64,6 +71,15 @@ namespace EgwProxy.SqlDb.Controllers
return fatto;
}
/// <summary>
/// Dispose classe
/// </summary>
public void Dispose()
{
// Clear database context
connString = "";
}
/// <summary>
/// Recupera la tab FluxLog x i record successivi all'ID già processato
/// </summary>
@@ -75,10 +91,29 @@ namespace EgwProxy.SqlDb.Controllers
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.DbSetMachFluxLog
.Where(x => x.Id > lastIdx)
.OrderBy(x => x.Id)
.ToList();
.DbSetMachFluxLog
.Where(x => x.Id > lastIdx)
.OrderBy(x => x.Id)
.ToList();
}
return dbResult;
}
/// <summary>
/// Recupera la tab PODL Macchina x i record successivi all'ID già processato
/// </summary>
/// <param name="lastIdx"></param>
/// <returns></returns>
public List<MachPODLModel> MachPOdlGetNew(int lastIdx)
{
List<MachPODLModel> dbResult = new List<MachPODLModel>();
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.DbSetMachPODL
.Where(x => x.IdxPromessa > lastIdx)
.OrderBy(x => x.IdxPromessa)
.ToList();
}
return dbResult;
}
@@ -94,10 +129,10 @@ namespace EgwProxy.SqlDb.Controllers
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.DbSetMachProdData
.Where(x => x.Id > lastIdx)
.OrderBy(x => x.Id)
.ToList();
.DbSetMachProdData
.Where(x => x.Id > lastIdx)
.OrderBy(x => x.Id)
.ToList();
}
return dbResult;
}
@@ -126,7 +161,7 @@ namespace EgwProxy.SqlDb.Controllers
/// </summary>
/// <param name="CurrPodlReq"></param>
/// <returns></returns>
public bool PodlWriteReq(List<MesPODLReqModel> CurrPodlReq)
public bool MesPodlWriteReq(List<MesPODLReqModel> CurrPodlReq)
{
bool fatto = false;
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
@@ -166,13 +201,13 @@ namespace EgwProxy.SqlDb.Controllers
{
dbResult = dbSyncStateCtx
.Database
.SqlQuery<MesPODLReqModel>("EXEC dbo.ResetPodlMes")
.SqlQuery<MesPODLReqModel>("EXEC dbo.stp_ResetPodlMes")
.ToList();
}
return dbResult;
}
public string serverOk()
public string ServerOk()
{
return SyncStateGetAll().Count() > 0 ? "OK" : "NA";
}
@@ -188,9 +223,9 @@ namespace EgwProxy.SqlDb.Controllers
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.Database
.SqlQuery<SyncStateModel>("EXEC dbo.stp_ExportAll")
.ToList();
.Database
.SqlQuery<SyncStateModel>("EXEC dbo.stp_ExportAll")
.ToList();
}
return dbResult;
}
@@ -206,9 +241,9 @@ namespace EgwProxy.SqlDb.Controllers
using (var dbSyncStateCtx = new SyncStateDbContext(connString))
{
dbResult = dbSyncStateCtx
.Database
.SqlQuery<SyncStateModel>("EXEC dbo.stp_ImportAll")
.ToList();
.Database
.SqlQuery<SyncStateModel>("EXEC dbo.stp_ImportAll")
.ToList();
}
return dbResult;
}
@@ -228,6 +263,7 @@ namespace EgwProxy.SqlDb.Controllers
}
return dbResult;
}
/// <summary>
/// Aggiorna record SyncState corrente
/// </summary>
@@ -239,11 +275,11 @@ namespace EgwProxy.SqlDb.Controllers
{
// cerco record
var dbResult = dbSyncStateCtx
.DbSetSyncState
.Where(x => x.TableName == newVal.TableName)
.FirstOrDefault();
.DbSetSyncState
.Where(x => x.TableName == newVal.TableName)
.FirstOrDefault();
// se trovato aggiorno
if(dbResult!=null)
if (dbResult != null)
{
dbResult.LastIdx = newVal.LastIdx;
dbResult.Note = newVal.Note;
@@ -253,7 +289,7 @@ namespace EgwProxy.SqlDb.Controllers
// altrimenti aggiungo
else
{
dbSyncStateCtx.DbSetSyncState.Add(newVal);
dbSyncStateCtx.DbSetSyncState.Add(newVal);
}
// salvo
EgwProxy.SqlDb/EgwProxy.SqlDb.csproj
+3
View File
@@ -98,7 +98,10 @@
</ItemGroup>
<ItemGroup>
<None Include="App.config" />
<None Include="docfx.json" />
<None Include="index.md" />
<None Include="packages.config" />
<None Include="toc.yml" />
</ItemGroup>
<ItemGroup>
<Content Include="SqlScript\AddFunc.sql">