AppStd/Modules
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Jobs: truncate table before 'clearbeforefill'

Browse Source
This commit is contained in:
Jonathan Jenne 2024-01-22 11:57:45 +01:00
parent f3eef04a09
commit 8362e1885d
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
Jobs/GraphQL/GraphQLJob.vb
View File

@ -119,17 +119,21 @@ Public Class GraphQLJob
' Clear Table before inserting ' Clear Table before inserting
If pQuery.ClearBeforeFill = True Then If pQuery.ClearBeforeFill = True Then
If DeleteWithQueryName(pQuery) = False Then If DeleteHistoryTable(pQuery) = False Then
Throw New ApplicationException($"Error while dropping history table before fill for Query [{pQuery.Name}]") Throw New ApplicationException($"Error while dropping history table before fill for Query [{pQuery.Name}]")
End If End If
If CreateHistoryTable(pQuery) = False Then If CreateHistoryTable(pQuery) = False Then
Throw New ApplicationException($"Error while creating history table before fill for Query [{pQuery.Name}]") Throw New ApplicationException($"Error while creating history table before fill for Query [{pQuery.Name}]")
End If End If
If TruncateTable(pQuery) = False Then
Throw New ApplicationException($"Error while truncating table before fill for Query [{pQuery.Name}]")
End If
End If End If
' Reset all records to status = 0 ' Reset all records to status = 0
If pQuery.ClearBeforeFill = False Then If pQuery.ClearBeforeFill = False Then
_Logger.Info("Resetting data for Query [{0}]", pQuery.Name) _Logger.Info("Resetting data for Query [{0}]", pQuery.Name)
If UpdateWithStatus(pQuery, 0) = False Then If UpdateWithStatus(pQuery, 0) = False Then
Throw New ApplicationException($"Error while resetting status of current Records for Query [{pQuery.Name}]") Throw New ApplicationException($"Error while resetting status of current Records for Query [{pQuery.Name}]")
@ -200,7 +204,7 @@ Public Class GraphQLJob
End Try End Try
End Function End Function
Private Function DeleteWithQueryName(pQuery As GraphQL.Query) As Boolean Private Function DeleteHistoryTable(pQuery As Query) As Boolean
Dim oHistoryTableName = $"{pQuery.DestinationTable}_HISTORY" Dim oHistoryTableName = $"{pQuery.DestinationTable}_HISTORY"
Dim oDeleteHistorySQL = $" Dim oDeleteHistorySQL = $"
IF (EXISTS (SELECT * IF (EXISTS (SELECT *
@ -214,6 +218,12 @@ Public Class GraphQLJob
Return _MSSQL.ExecuteNonQuery(oDeleteHistorySQL) Return _MSSQL.ExecuteNonQuery(oDeleteHistorySQL)
End Function End Function
Private Function TruncateTable(pQuery As Query)
Dim oDeleteTableSQL = $"TRUNCATE TABLE {pQuery.DestinationTable}"
Return _MSSQL.ExecuteNonQuery(oDeleteTableSQL)
End Function
Private Function CreateHistoryTable(pQuery As Query) As Boolean Private Function CreateHistoryTable(pQuery As Query) As Boolean
Dim oHistoryTableName = $"{pQuery.DestinationTable}_HISTORY" Dim oHistoryTableName = $"{pQuery.DestinationTable}_HISTORY"
Dim oFillHistorySQL = $"SELECT * INTO {oHistoryTableName} FROM {pQuery.DestinationTable}" Dim oFillHistorySQL = $"SELECT * INTO {oHistoryTableName} FROM {pQuery.DestinationTable}"