glm94/advertisingprofitcontrol-alpha
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Files
d8c753f788d48b36e083f181c050e8fb6c443075
advertisingprofitcontrol-alpha/AdvertsingProfitControl/DatabaseWriter.cs
T

2293 lines
117 KiB
C#
Raw Blame History

using System.Collections.Generic;
using System.Data;
using System.Data.OleDb;
using System.Windows.Forms;
namespace AdvertsingProfitControl
{
internal class DatabaseWriter
{
private readonly OleDbConnection _oleDbConnection = new OleDbConnection();
private readonly FrmLogConsole _logConsole = FrmLogConsole.GetStaticInstance;
public DatabaseWriter(string connectionString)
{
_oleDbConnection.ConnectionString = connectionString;
}
#region New Code
/// <summary>
/// Inserts new records into the specified sales table.
/// Supports rolling back the database to prevent corruption.
/// </summary>
/// <param name="salesTable">The data table that contains the data to be inserted.</param>
/// <param name="connectionString">A string pointing to the database.</param>
/// <returns>A DbWriterStatus object that contains a status, rows added and an error message if necessary.</returns>
public DbWriterStatus InsertIntoSalesTable(DataTable salesTable, string connectionString)
{
var lastRowProcessed = 0;
var writerStatus = new DbWriterStatus();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
OleDbTransaction oleDbTransaction = null;
try
{
oleDbConnection.Open();
oleDbTransaction = oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
for (var i = 0; i < salesTable.Rows.Count; i++)
{
oleDbCommand.CommandText =
"INSERT INTO " + salesTable.TableName + " (Sold, SalePrice, TotalSales, Cost, ProfitReturn, TotalProfitReturn, FK_AdItemID, RowAttribute, FK_AdSpecialGroupName, RowPosition, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
//New Sales Table Layout (Based on the Database's Physical Layout)
//0: Sold 1:SalePrice 2:TotalSales 3:cost 4:ProfitReturn 5:TotalProfitReturn
//6:FK_AdItemID 7:RowAttribute 8:FK_AdSpecialGroupName (ID) 9:RowPosition (not index based)
//10:FK_DateID
oleDbCommand.Parameters.AddWithValue("Sold", salesTable.Rows[i][0]);
oleDbCommand.Parameters.AddWithValue("SalesPrice", salesTable.Rows[i][1]);
oleDbCommand.Parameters.AddWithValue("TotalSales", salesTable.Rows[i][2]);
oleDbCommand.Parameters.AddWithValue("Cost", salesTable.Rows[i][3]);
oleDbCommand.Parameters.AddWithValue("ProfitReturn", salesTable.Rows[i][4]);
oleDbCommand.Parameters.AddWithValue("TotalProfitReturn", salesTable.Rows[i][5]);
oleDbCommand.Parameters.AddWithValue("adItemID", int.Parse(salesTable.Rows[i][6].ToString()));
oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(salesTable.Rows[i][7].ToString()));
oleDbCommand.Parameters.AddWithValue("adSpecialID", int.Parse(salesTable.Rows[i][8].ToString()));
oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(salesTable.Rows[i][9].ToString()));
oleDbCommand.Parameters.AddWithValue("dateID", int.Parse(salesTable.Rows[i][10].ToString()));
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
//Row index is only used to keep track of what row failed to update.
lastRowProcessed = int.Parse(salesTable.Rows[i][9].ToString()) - 1;
}
oleDbTransaction.Commit();
foreach (DataRow row in salesTable.Rows)
{
var rowId = RetrieveRowId(salesTable.TableName, int.Parse(row[6].ToString()), int.Parse(row[10].ToString()), int.Parse(salesTable.Rows[8].ToString()));
if (int.Parse(row[8].ToString()) != 0)
{
//Account for the ad special row.
//Index 8 of the row indicates that this row is an ad special member row
//so we must add one to the row position to offset the fact that a row
//is "missing" from this DataTable.
//Row[9] is its row position, which is not zero index based.
writerStatus.AddRowId(int.Parse(row[9].ToString()) + 1, rowId);
}
else
{
//The ad special row doesn't exist so no need to offset it.
writerStatus.AddRowId(int.Parse(row[9].ToString()), rowId);
}
}
writerStatus.SetStatus(WritingOperationStatus.InsertionSuccessful);
}
catch (OleDbException ex)
{
writerStatus.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write to database: " + ex.Message);
if (lastRowProcessed <= 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to begin parsing data rows, var dump of erroneous row unavailable.");
writerStatus.SetErrorMessage("Failed to begin parsing rows.");
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + salesTable.TableName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Ad Item ID: \"" +
salesTable.Rows[lastRowProcessed][6] + "\" Sold: \"" + salesTable.Rows[lastRowProcessed][0] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Sale Price: \"" + salesTable.Rows[lastRowProcessed][1] + "\" Total Sales: \"" + salesTable.Rows[lastRowProcessed][2] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Cost: \"" + salesTable.Rows[lastRowProcessed][3] + "\" Profit Return: \"" + salesTable.Rows[lastRowProcessed][4] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Total Profit Return: \"" +
salesTable.Rows[lastRowProcessed][5] + "\" Ad Special Group: \"" + salesTable.Rows[lastRowProcessed][8] + "\"");
writerStatus.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + ".");
}
oleDbTransaction?.Rollback();
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + salesTable.TableName+ " table failed on insertion.");
}
finally
{
oleDbConnection.Close();
}
return writerStatus;
}
/// <summary>
/// Updates existing records in the database for either the Projections
/// table or the Actual Sales table.
/// Supports database rollback.
/// </summary>
/// <param name="salesTable">The data table that contains the data to be inserted.</param>
/// <param name="connectionString">A string pointing to the database.</param>
/// <returns>A DbWriterStatus object that contains a status, rows added and an error message if necessary.</returns>
public DbWriterStatus UpdateSalesTable(DataTable salesTable, string connectionString)
{
var updateStatus = new DbWriterStatus();
var lastRowProccessed = 0;
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
OleDbTransaction oleDbTransaction = null;
try
{
oleDbConnection.Open();
oleDbTransaction = oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
for (var i = 0; i < salesTable.Rows.Count; i++)
{
oleDbCommand.CommandText =
"UPDATE " + salesTable.TableName + " SET Sold = ?, SalePrice = ?, TotalSales = ?, Cost = ?, ProfitReturn = ?, TotalProfitReturn = ?, FK_AdItemID = ?, RowAttribute = ?, FK_AdSpecialGroupName = ?, RowPosition = ? WHERE ID = ?";
//Update Sales Table Layout (Based on the Database's Physical Layout)
//0:ID 1:Sold 2:SalePrice 3:TotalSales 4:cost 5:ProfitReturn 6:TotalProfitReturn
//7:FK_AdItemID 8:RowAttribute 9:FK_AdSpecialGroupName (ID) 10:RowPosition (not index based)
//11:FK_DateID
oleDbCommand.Parameters.AddWithValue("Sold", salesTable.Rows[i][1]);
oleDbCommand.Parameters.AddWithValue("SalesPrice", salesTable.Rows[i][2]);
oleDbCommand.Parameters.AddWithValue("TotalSales", int.Parse(salesTable.Rows[i][3].ToString()));
oleDbCommand.Parameters.AddWithValue("Cost", int.Parse(salesTable.Rows[i][4].ToString()));
oleDbCommand.Parameters.AddWithValue("ProfitReturn", int.Parse(salesTable.Rows[i][5].ToString()));
oleDbCommand.Parameters.AddWithValue("TotalProfitReturn", int.Parse(salesTable.Rows[i][6].ToString()));
oleDbCommand.Parameters.AddWithValue("FK_AdItemID", int.Parse(salesTable.Rows[i][7].ToString()));
oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(salesTable.Rows[i][8].ToString()));
oleDbCommand.Parameters.AddWithValue("adSpecialID", int.Parse(salesTable.Rows[i][9].ToString()));
oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(salesTable.Rows[i][10].ToString()));
oleDbCommand.Parameters.AddWithValue("ID", int.Parse(salesTable.Rows[i][0].ToString()));
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
//Row index is only used to keep track of what row failed to update.
lastRowProccessed = int.Parse(salesTable.Rows[i][10].ToString()) - 1;
}
oleDbTransaction.Commit();
foreach (DataRow row in salesTable.Rows)
{
if (int.Parse(row[9].ToString()) != 0)
{
//Account for the ad special row.
//Index 10 of the row indicates that this row is an ad special member row
//so we must add one to the row position to offset the fact that a row
//is "missing" from this DataTable.
//Row[10] is its row position, which is not zero index based.
updateStatus.AddRowId(int.Parse(row[10].ToString()) + 1, int.Parse(row[0].ToString()));
}
else
{
//The ad special row doesn't exist so no need to offset it.
updateStatus.AddRowId(int.Parse(row[10].ToString()), int.Parse(row[0].ToString()));
}
}
updateStatus.SetStatus(WritingOperationStatus.UpdateSuccessful);
}
catch (OleDbException ex)
{
updateStatus.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + salesTable.TableName + ": " + ex.Message);
if (lastRowProccessed <= 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to begin parsing data rows, var dump of erroneous row unavailable.");
updateStatus.SetErrorMessage("Failed to begin parsing rows.");
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed on row " + (lastRowProccessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProccessed + 1) + " from " + salesTable.TableName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Ad Item ID: \"" +
salesTable.Rows[lastRowProccessed][7] + "\" Sold: \"" + salesTable.Rows[lastRowProccessed][1] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Sale Price: \"" + salesTable.Rows[lastRowProccessed][2] + "\" Total Sales: \"" + salesTable.Rows[lastRowProccessed][3] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Cost: \"" + salesTable.Rows[lastRowProccessed][4] + "\" Profit Return: \"" + salesTable.Rows[lastRowProccessed][5] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Total Profit Return: \"" +
salesTable.Rows[lastRowProccessed][6] + "\" Ad Special Group: \"" + salesTable.Rows[lastRowProccessed][9] + "\"");
updateStatus.SetErrorMessage("Failed to write to the database on row " + (lastRowProccessed + 1) + ".");
}
oleDbTransaction?.Rollback();
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + salesTable.TableName + " table failed on update.");
}
finally
{
oleDbConnection.Close();
}
return updateStatus;
}
/// <summary>
/// Inserts new records into the Inventory table.
/// Supports database rollback.
/// </summary>
/// <param name="table">The data table that contains the data to be inserted.</param>
/// <param name="connectionString">A string pointing to the database.</param>
/// <returns>A DbWriterStatus object that contains a status, rows added and an error message if necessary.</returns>
public DbWriterStatus InsertIntoInventoryTable(DataTable table, string connectionString)
{
var status = new DbWriterStatus();
var lastRowProcessed = 0;
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
OleDbTransaction oleDbTransaction = null;
try
{
oleDbConnection.Open();
oleDbTransaction = oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
for (var i = 0; i < table.Rows.Count; i++)
{
oleDbCommand.CommandText =
"INSERT INTO " + table.TableName + " (BeginningInventory, Received, TotalInventory, EndingInventory, FK_AdItemID, RowAttribute, FK_AdSpecialGroupName, RowPosition, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)";
//New inventory Table Layout (Based on the Database's Physical Layout)
//0:Beginning Inventory 1:Received 2:Total Inventory 3:Ending Inventory
//4:AdItemID 5:RowAttribute 6:GroupID 7:RowPosition 8:DateID
oleDbCommand.Parameters.AddWithValue("BegnningInventory", table.Rows[i][0]);
oleDbCommand.Parameters.AddWithValue("Received", table.Rows[i][1]);
oleDbCommand.Parameters.AddWithValue("TotalInventory", table.Rows[i][2]);
oleDbCommand.Parameters.AddWithValue("EndingInventory", table.Rows[i][3]);
oleDbCommand.Parameters.AddWithValue("AdItemID", int.Parse(table.Rows[i][4].ToString()));
oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(table.Rows[i][5].ToString()));
oleDbCommand.Parameters.AddWithValue("FK_AdSpecialGroup", int.Parse(table.Rows[i][6].ToString()));
oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(table.Rows[i][7].ToString()));
oleDbCommand.Parameters.AddWithValue("DateID", int.Parse(table.Rows[i][8].ToString()));
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
//Row index is only used to keep track of what row failed to update.
lastRowProcessed = int.Parse(table.Rows[i][7].ToString()) - 1;
}
oleDbTransaction.Commit();
foreach (DataRow row in table.Rows)
{
var rowId = RetrieveRowId(table.TableName, int.Parse(row[4].ToString()), int.Parse(row[8].ToString()), int.Parse(table.Rows[6].ToString()));
if (int.Parse(row[6].ToString()) != 0)
{
//Account for the ad special row.
//Index 8 of the row indicates that this row is an ad special member row
//so we must add one to the row position to offset the fact that a row
//is "missing" from this DataTable.
//Row[7] is its row position, which is not zero index based.
status.AddRowId(int.Parse(row[7].ToString()) + 1, rowId);
}
else
{
//The ad special row doesn't exist so no need to offset it.
status.AddRowId(int.Parse(row[7].ToString()), rowId);
}
}
status.SetStatus(WritingOperationStatus.InsertionSuccessful);
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + table.TableName + ": " + e.Message);
if (lastRowProcessed <= 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to begin parsing data rows, var dump of erroneous row unavailable.");
status.SetErrorMessage("Failed to begin parsing rows.");
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + table.TableName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + table.Rows[lastRowProcessed][4] + "\" Beginning Inventory: \"" + table.Rows[lastRowProcessed][0]);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Received: \"" + table.Rows[lastRowProcessed][1] + "\" Total Inventory: \"" + table.Rows[lastRowProcessed][2] + "\" Ending Inventory: \"" + table.Rows[lastRowProcessed][3] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Row Attribute: \"" + table.Rows[lastRowProcessed][5] + "\" Ad Special ID: \"" + table.Rows[lastRowProcessed][7] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Date ID: \"" + table.Rows[lastRowProcessed][8] + "\"");
status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + ".");
}
oleDbTransaction?.Rollback();
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + table.TableName + " table failed on update.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
/// <summary>
/// Updates the Inventory table using the supplied DataTable
/// Supports rolling back the database.
/// </summary>
/// <param name="table">The table with the changes to be made.</param>
/// <param name="connectionString">A string pointing to the database.</param>
/// <returns>A DbWriterStatus object that contains a status, rows added and an error message if necessary.</returns>
public DbWriterStatus UpdateInventoryTable(DataTable table, string connectionString)
{
var status = new DbWriterStatus();
var lastRowProcessed = 0;
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
OleDbTransaction oleDbTransaction = null;
try
{
oleDbConnection.Open();
oleDbTransaction = oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
for (var i = 0; i < table.Rows.Count; i++)
{
oleDbCommand.CommandText =
"UPDATE " + table.TableName + " SET BeginningInventory = ?, Received =? , TotalInventory = ?, EndingInventory = ?, FK_AdItemID = ?, RowAttribute = ?, FK_AdSpecialGroupName = ?, RowPosition = ? WHERE ID = ?";
//0:ID 1:BeginningInventory 2:Received 3:TotalInventory 4:EndingInventory
//5:AdItemID 6:RowAttribute 7:GroupID 8:RowPosition 9:DateID
oleDbCommand.Parameters.AddWithValue("BegnningInventory", table.Rows[i][1]);
oleDbCommand.Parameters.AddWithValue("Received", table.Rows[i][2]);
oleDbCommand.Parameters.AddWithValue("TotalInventory", table.Rows[i][3]);
oleDbCommand.Parameters.AddWithValue("EndingInventory", table.Rows[i][4]);
oleDbCommand.Parameters.AddWithValue("AdItemID", int.Parse(table.Rows[i][5].ToString()));
oleDbCommand.Parameters.AddWithValue("RowAttribute", int.Parse(table.Rows[i][6].ToString()));
oleDbCommand.Parameters.AddWithValue("FK_AdSpecialGroup", int.Parse(table.Rows[i][7].ToString()));
oleDbCommand.Parameters.AddWithValue("RowPosition", int.Parse(table.Rows[i][8].ToString()));
oleDbCommand.Parameters.AddWithValue("ID", int.Parse(table.Rows[i][0].ToString()));
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
//Row index is only used to keep track of what row failed to update.
lastRowProcessed = int.Parse(table.Rows[i][8].ToString()) - 1;
}
oleDbTransaction.Commit();
foreach (DataRow row in table.Rows)
{
var rowId = RetrieveRowId(table.TableName, int.Parse(row[4].ToString()), int.Parse(row[8].ToString()), int.Parse(table.Rows[7].ToString()));
if (int.Parse(row[7].ToString()) != 0)
{
//Account for the ad special row.
//Index 8 of the row indicates that this row is an ad special member row
//so we must add one to the row position to offset the fact that a row
//is "missing" from this DataTable.
//Row[8] is its row position, which is not zero index based.
status.AddRowId(int.Parse(row[8].ToString()) + 1, rowId);
}
else
{
//The ad special row doesn't exist so no need to offset it.
status.AddRowId(int.Parse(row[8].ToString()), rowId);
}
}
status.SetStatus(WritingOperationStatus.InsertionSuccessful);
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the database for " + table.TableName + ": " + e.Message);
if (lastRowProcessed <= 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to begin parsing data rows, var dump of erroneous row unavailable.");
status.SetErrorMessage("Failed to begin parsing rows.");
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from " + table.TableName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad Item ID: \"" + table.Rows[lastRowProcessed][4] + "\" Beginning Inventory: \"" + table.Rows[lastRowProcessed][0]);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Received: \"" + table.Rows[lastRowProcessed][1] + "\" Total Inventory: \"" + table.Rows[lastRowProcessed][2] + "\" Ending Inventory: \"" + table.Rows[lastRowProcessed][3] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Row Attribute: \"" + table.Rows[lastRowProcessed][5] + "\" Ad Special ID: \"" + table.Rows[lastRowProcessed][7] + "\"");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Date ID: \"" + table.Rows[lastRowProcessed][8] + "\"");
status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + ".");
}
oleDbTransaction?.Rollback();
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, " + table.TableName + " table failed on update.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
public DbWriterStatus ProccessInvoiceTable(DataGridView table, int dateId, string connectionString)
{
var status = new DbWriterStatus();
var lastRowProcessed = 0;
var rowsAdded = new List<int>();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
OleDbTransaction oleDbTransaction = null;
try
{
oleDbConnection.Open();
oleDbTransaction = oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
for (var i = 0; i < table.Rows.Count - 1; i++)
{
//Check to see if the row requires processing to start with.
if(!(bool) table.Rows[i].Cells[(int)InvoiceTableColumns.IsDirty].Value)
{
lastRowProcessed = i + 1;
continue;
}
//Grab the supplier ID number before moving forward.
var supplierId = RetrieveSupplierId(
table.Rows[i].Cells[(int) InvoiceTableColumns.Supplier].EditedFormattedValue.ToString());
if (supplierId == 0)
{
status.SetErrorMessage("Failed to obtain supplier ID number for " + table.Rows[i].Cells[(int)InvoiceTableColumns.Supplier].EditedFormattedValue + ".");
status.SetStatus(WritingOperationStatus.Failed);
return status;
}
//Check whether or not the row is already in the database by seeing if anything is in the ID number cell.
if (table.Rows[i].Cells[(int) InvoiceTableColumns.Id].EditedFormattedValue.ToString() == "")
{
//If the invoice doesn't exist in the database add it.
oleDbCommand.CommandText =
"INSERT INTO Invoice (InvoiceDate, InvoiceNumber, InvoiceNetAmountAtCost, InvoiceNetAmount, InvoiceNote, FK_Supplier, FK_DateID) VALUES(?,?,?,?,?,?,?)";
oleDbCommand.Parameters.AddWithValue("InvoiceDate", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue.ToString());
oleDbCommand.Parameters.AddWithValue("InvoiceNumber", long.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNote", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNote].EditedFormattedValue.ToString());
oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId);
oleDbCommand.Parameters.AddWithValue("FK_DateID", dateId);
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
rowsAdded.Add(i);
}
else
{
//If the invoice already exists in the database then simply update the record.
oleDbCommand.CommandText =
"UPDATE Invoice SET InvoiceDate = ?, InvoiceNumber = ?, InvoiceNetAmountAtCost = ?, InvoiceNetAmount = ?, InvoiceNote = ?, FK_Supplier = ?, FK_DateID = ? WHERE ID = ?";
oleDbCommand.Parameters.AddWithValue("InvoiceDate", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue.ToString());
oleDbCommand.Parameters.AddWithValue("InvoiceNumber", long.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmountAtCost].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString() == "" ? 0 : double.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNetAmount].EditedFormattedValue.ToString()));
oleDbCommand.Parameters.AddWithValue("InvoiceNote", table.Rows[i].Cells[(int)InvoiceTableColumns.InvoiceNote].EditedFormattedValue.ToString());
oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId);
oleDbCommand.Parameters.AddWithValue("FK_DateID", dateId);
oleDbCommand.Parameters.AddWithValue("ID", int.Parse(table.Rows[i].Cells[(int)InvoiceTableColumns.Id].EditedFormattedValue.ToString()));
oleDbCommand.ExecuteNonQuery();
oleDbCommand.Parameters.Clear();
}
//Row index is only used to keep track of what row failed to update.
lastRowProcessed = i + 1;
}
oleDbTransaction.Commit();
foreach (DataGridViewRow row in table.Rows)
{
if (rowsAdded.Contains(row.Index))
{
var supplierId = RetrieveSupplierId(row.Cells[(int)InvoiceTableColumns.Supplier].EditedFormattedValue.ToString());
var invoiceIdNumber =
RetrieveInvoiceId(
row.Cells[(int)InvoiceTableColumns.InvoiceDate].EditedFormattedValue
.ToString(),
long.Parse(
row.Cells[(int)InvoiceTableColumns.InvoiceNumber].EditedFormattedValue
.ToString()), supplierId, dateId);
row.Cells[(int)InvoiceTableColumns.Id].Value = invoiceIdNumber;
}
row.Cells[(int)InvoiceTableColumns.IsDirty].Value = false;
}
table.RefreshEdit();
//Set the status.
status.SetStatus(WritingOperationStatus.InsertionSuccessful);
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the Invoice table: " + e.Message);
if (lastRowProcessed <= 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to begin parsing data rows, var dump of erroneous row unavailable.");
status.SetErrorMessage("Failed to begin parsing rows.");
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed on row " + (lastRowProcessed + 1) + " due to the above error. Dumping contents of row " + (lastRowProcessed + 1) + " from Invoices.");
status.SetErrorMessage("Failed to write to the database on row " + (lastRowProcessed + 1) + ".");
}
oleDbTransaction?.Rollback();
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Rollback completed successfully, Invoice table failed on update.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
public DbWriterStatus ProcessComments(string comments, int dateId, string connectionString, int id = 0)
{
var status = new DbWriterStatus();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
try
{
oleDbConnection.Open();
if (id == 0)
{
oleDbCommand.CommandText = "INSERT INTO Comment (Comment, FK_DateID) VALUES (?, ?)";
oleDbCommand.Parameters.AddWithValue("Comment", comments);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.ExecuteNonQuery();
//Now grab the ID number of the comment that was just added.
oleDbCommand.CommandText = "SELECT ID FROM Comment WHERE FK_DateID = ?";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
//Now read the ID number and add it to the collection with a default key.
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
status.AddRowId(0, int.Parse(reader[0].ToString()));
}
}
else
{
oleDbCommand.CommandText = "UPDATE Comment SET Comment = ? WHERE ID = ?";
oleDbCommand.Parameters.AddWithValue("Comment", comments);
oleDbCommand.Parameters.AddWithValue("ID", id);
oleDbCommand.ExecuteNonQuery();
}
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the comment(s): " + e.Message);
status.SetErrorMessage("Failed to update or insert comments into the database.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
public DbWriterStatus ProcessWeeklySales(double[] weeklySales, int dateId, string connectionString, int id = 0)
{
var status = new DbWriterStatus();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
try
{
oleDbConnection.Open();
if (id == 0)
{
oleDbCommand.CommandText = "INSERT INTO WeeklySales (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, TotalSales, FK_DateID) VALUES (?,?,?,?,?,?,?,?,?)";
oleDbCommand.Parameters.AddWithValue("Sunday", weeklySales[0]);
oleDbCommand.Parameters.AddWithValue("Monday", weeklySales[1]);
oleDbCommand.Parameters.AddWithValue("Tuesday", weeklySales[2]);
oleDbCommand.Parameters.AddWithValue("Wednesday", weeklySales[3]);
oleDbCommand.Parameters.AddWithValue("Thursday", weeklySales[4]);
oleDbCommand.Parameters.AddWithValue("Friday", weeklySales[5]);
oleDbCommand.Parameters.AddWithValue("Saturday", weeklySales[6]);
oleDbCommand.Parameters.AddWithValue("TotalSales", weeklySales[7]);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.ExecuteNonQuery();
//Now grab the ID number of the comment that was just added.
oleDbCommand.CommandText = "SELECT ID FROM WeeklySales WHERE FK_DateID = ?";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
//Now read the ID number and add it to the collection with a default key.
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
status.AddRowId(0, int.Parse(reader[0].ToString()));
}
}
else
{
oleDbCommand.CommandText = "UPDATE WeeklySales SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, TotalSales = ? WHERE ID = ?";
oleDbCommand.Parameters.AddWithValue("Sunday", weeklySales[0]);
oleDbCommand.Parameters.AddWithValue("Monday", weeklySales[1]);
oleDbCommand.Parameters.AddWithValue("Tuesday", weeklySales[2]);
oleDbCommand.Parameters.AddWithValue("Wednesday", weeklySales[3]);
oleDbCommand.Parameters.AddWithValue("Thursday", weeklySales[4]);
oleDbCommand.Parameters.AddWithValue("Friday", weeklySales[5]);
oleDbCommand.Parameters.AddWithValue("Saturday", weeklySales[6]);
oleDbCommand.Parameters.AddWithValue("TotalSales", weeklySales[7]);
oleDbCommand.Parameters.AddWithValue("ID", id);
oleDbCommand.ExecuteNonQuery();
}
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the weekly sales: " + e.Message);
status.SetErrorMessage("Failed to update or insert weekly sales into the database.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
public DbWriterStatus ProcessTaxable(double[] taxable, int dateId, string connectionString, int id = 0)
{
var status = new DbWriterStatus();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
try
{
oleDbConnection.Open();
if (id == 0)
{
oleDbCommand.CommandText = "INSERT INTO Taxable (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, Total, FK_DateID) VALUES (?,?,?,?,?,?,?,?,?)";
oleDbCommand.Parameters.AddWithValue("Sunday", taxable[0]);
oleDbCommand.Parameters.AddWithValue("Monday", taxable[1]);
oleDbCommand.Parameters.AddWithValue("Tuesday", taxable[2]);
oleDbCommand.Parameters.AddWithValue("Wednesday", taxable[3]);
oleDbCommand.Parameters.AddWithValue("Thursday", taxable[4]);
oleDbCommand.Parameters.AddWithValue("Friday", taxable[5]);
oleDbCommand.Parameters.AddWithValue("Saturday", taxable[6]);
oleDbCommand.Parameters.AddWithValue("TotalSales", taxable[7]);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.ExecuteNonQuery();
//Now grab the ID number of the comment that was just added.
oleDbCommand.CommandText = "SELECT ID FROM Taxable WHERE FK_DateID = ?";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
//Now read the ID number and add it to the collection with a default key.
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
status.AddRowId(0, int.Parse(reader[0].ToString()));
}
}
else
{
oleDbCommand.CommandText = "UPDATE Taxable SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, Total = ? WHERE ID = ?";
oleDbCommand.Parameters.AddWithValue("Sunday", taxable[0]);
oleDbCommand.Parameters.AddWithValue("Monday", taxable[1]);
oleDbCommand.Parameters.AddWithValue("Tuesday", taxable[2]);
oleDbCommand.Parameters.AddWithValue("Wednesday", taxable[3]);
oleDbCommand.Parameters.AddWithValue("Thursday", taxable[4]);
oleDbCommand.Parameters.AddWithValue("Friday", taxable[5]);
oleDbCommand.Parameters.AddWithValue("Saturday", taxable[6]);
oleDbCommand.Parameters.AddWithValue("TotalSales", taxable[7]);
oleDbCommand.Parameters.AddWithValue("ID", id);
oleDbCommand.ExecuteNonQuery();
}
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the taxable: " + e.Message);
status.SetErrorMessage("Failed to update or insert taxable into the database.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
public DbWriterStatus ProcessCostAnalysis(double[] costAnalysis, int dateId, string connectionString, int id = 0)
{
var status = new DbWriterStatus();
var oleDbConnection = new OleDbConnection(connectionString);
var oleDbCommand = new OleDbCommand
{
Connection = oleDbConnection
};
try
{
oleDbConnection.Open();
if (id == 0)
{
oleDbCommand.CommandText = "INSERT INTO CostOfSalesAnalysis (SalesPerManHour, SalaryPercentage, SalaryDollars, Supplies, FK_dateID) VALUES (?,?,?,?,?)";
oleDbCommand.Parameters.AddWithValue("SalesPerManHour", costAnalysis[0]);
oleDbCommand.Parameters.AddWithValue("SalaryPercentage", costAnalysis[1]);
oleDbCommand.Parameters.AddWithValue("SalaryDollars", costAnalysis[2]);
oleDbCommand.Parameters.AddWithValue("Supplies", costAnalysis[3]);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.ExecuteNonQuery();
//Now grab the ID number of the comment that was just added.
oleDbCommand.CommandText = "SELECT ID FROM Taxable WHERE FK_DateID = ?";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
//Now read the ID number and add it to the collection with a default key.
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
status.AddRowId(0, int.Parse(reader[0].ToString()));
}
}
else
{
oleDbCommand.CommandText = "UPDATE CostOfSalesAnalysis SET SalesPerManHour = ?, SalaryPercentage = ?, SalaryDollars = ?, Supplies = ? WHERE ID = ?";
oleDbCommand.Parameters.AddWithValue("SalesPerManHour", costAnalysis[0]);
oleDbCommand.Parameters.AddWithValue("SalaryPercentage", costAnalysis[1]);
oleDbCommand.Parameters.AddWithValue("SalaryDollars", costAnalysis[2]);
oleDbCommand.Parameters.AddWithValue("Supplies", costAnalysis[3]);
oleDbCommand.Parameters.AddWithValue("ID", id);
oleDbCommand.ExecuteNonQuery();
}
}
catch (OleDbException e)
{
status.SetStatus(WritingOperationStatus.Failed);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to process the taxable: " + e.Message);
status.SetErrorMessage("Failed to update or insert taxable into the database.");
}
finally
{
oleDbConnection.Close();
}
return status;
}
/// <summary>
/// Inserts a new ad item into the database and returns the new item's ID number.
/// Supports rolling back as to not corrupt the database.
/// </summary>
/// <param name="adItemName">The ad item's name that is to be added.</param>
/// <param name="oleDbCommand">A reference to a command that already has a transaction active.</param>
/// <returns>The ID number of the ad item that was just added.</returns>
public int InsertNewAdItem(string adItemName, OleDbCommand oleDbCommand = null)
{
var adItemId = 0;
var needsTransaction = false;
if (oleDbCommand == null)
{
oleDbCommand = new OleDbCommand
{
Connection = _oleDbConnection
};
needsTransaction = true;
}
oleDbCommand.CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("AdItem", adItemName);
OleDbTransaction oleDbTransaction = null;
try
{
if (needsTransaction)
{
//If the OleDbCommand object is not supplied, then we'll need to create and assign the transaction object.
oleDbCommand.Connection = _oleDbConnection;
_oleDbConnection.Open();
oleDbTransaction = _oleDbConnection.BeginTransaction();
oleDbCommand.Transaction = oleDbTransaction;
}
if (oleDbCommand.ExecuteNonQuery() == 1)
{
oleDbCommand.CommandText = "SELECT ID FROM AdItem WHERE AdItem.AdItem = ?";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("AdItem", adItemName);
var reader = oleDbCommand.ExecuteReader();
//Get the ID of the new ad item.
while (reader != null && reader.Read())
{
int.TryParse(reader[0].ToString(), out adItemId);
}
reader?.Close();
if (adItemId != 0)
{
//All was successful.
oleDbTransaction?.Commit();
}
else
{
//
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Ad item \"" + adItemName + "\" was not found in the database; rolling back changes.");
oleDbTransaction?.Rollback();
}
}
else
{
//Something failed but wasn't caught.
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to add the ad item \"" + adItemName + "\" into the database.");
oleDbTransaction?.Rollback();
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to insert ad item " + adItemName + " into the database.");
oleDbTransaction?.Rollback();
}
finally
{
if (needsTransaction)
{
_oleDbConnection.Close();
}
}
return adItemId;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code.
/// Grabs the ID of the specified row.
/// </summary>
/// <param name="tableName">The name of the table to check for the row in.</param>
/// <param name="adItemId">The ID of the ad item in the row.</param>
/// <param name="dateId">The ID of the date in the row.</param>
/// <param name="groupId">Ad Special ID of the row.</param>
/// <returns>The ID of the row, zero(0) if no rows are found.</returns>
private int RetrieveRowId(string tableName, int adItemId, int dateId, int groupId)
{
var id = 0;
var rowsEffected = 0;
var oleDbCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM " + tableName + " WHERE FK_AdItemID = ? AND FK_DateID = ? AND FK_AdSpecialGroupName = ?",
Connection = _oleDbConnection
};
oleDbCommand.Parameters.AddWithValue("AdItemID", adItemId);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.Parameters.AddWithValue("GroupID", groupId);
try
{
_oleDbConnection.Open();
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
int.TryParse(reader[0].ToString(), out id);
}
reader?.Close();
if (rowsEffected > 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Redundancy found row with the ad item ID " + adItemId + " with the date ID " + dateId + " and a group ID of " + groupId + ".");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to look up the existence of a row with the ad item ID " + adItemId + " with the date ID " + dateId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
_oleDbConnection.Close();
return id;
}
/// <summary>
/// Attempts to grab the supplier ID from the database.
/// If the name is not found it is added to the database
/// and the ID of the newly added supplier is returned.
/// </summary>
/// <param name="supplierName">The name of the supplier from whom the invoice is from.</param>
/// <returns></returns>
private int RetrieveSupplierId(string supplierName)
{
var id = 0;
var rowsEffected = 0;
var oleDbCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?",
Connection = _oleDbConnection
};
oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName);
try
{
_oleDbConnection.Open();
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
int.TryParse(reader[0].ToString(), out id);
}
reader?.Close();
if (rowsEffected == 0)
{
//Attempt to add the supplier to the database.
oleDbCommand.Parameters.Clear();
oleDbCommand.CommandText = "INSERT INTO Supplier (SupplierName) VALUES (?)";
oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName);
rowsEffected = oleDbCommand.ExecuteNonQuery();
if (rowsEffected == 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Info, "Added the supplier '" + supplierName + "' to the database.");
}
//Now try grabbing the ID of the supplier that was just added.
oleDbCommand.Parameters.Clear();
oleDbCommand.CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?";
oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName);
reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
int.TryParse(reader[0].ToString(), out id);
}
}
if (rowsEffected > 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"The supplier " + supplierName + " has multiple entries.");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to look up the existence of the supplier " + supplierName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return id;
}
/// <summary>
/// Retrieves the ID number of the invoice with the specified Date, Number and date ID numbers.
/// Returns zero if now records are found.
/// </summary>
/// <param name="invoiceDate">The date on the invoice.</param>
/// <param name="invoiceNumber">The number for the invoice.</param>
/// <param name="supplierId">The supplier's ID number.</param>
/// <param name="dateId">The date ID number of the weekending date.</param>
/// <returns></returns>
private int RetrieveInvoiceId(string invoiceDate, long invoiceNumber, int supplierId, int dateId)
{
var id = 0;
var rowsEffected = 0;
var oleDbCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM Invoice WHERE InvoiceDate = ? AND InvoiceNumber = ? AND FK_Supplier = ? AND FK_DateID = ?",
Connection = _oleDbConnection
};
oleDbCommand.Parameters.AddWithValue("InvoiceDate", invoiceDate);
oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceNumber);
oleDbCommand.Parameters.AddWithValue("FK_Supplier", supplierId);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
try
{
_oleDbConnection.Open();
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
int.TryParse(reader[0].ToString(), out id);
}
reader?.Close();
if (rowsEffected > 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Redundancy found row with the ad item ID with the date ID " + dateId + ".");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to look up the existence of an invoice with the number of " + invoiceNumber +
" and a date of " + invoiceDate + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return id;
}
#endregion
//10 to 1 ratio of tries to code
//http://codebetter.com/karlseguin/2006/04/05/understanding-and-using-exceptions/nfrastructure
public bool InsertIntoWeekEnding(string dateString)
{
//Assume the INSERT operation failed in case anything other error arises.
var insertWasSuccessful = false;
//Set up the command object, SQL command string and parameters.
var oleDbCommand = new OleDbCommand
{
CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES ( dateString )"
};
oleDbCommand.Parameters.AddWithValue("dateString", dateString);
oleDbCommand.Connection = _oleDbConnection;
//Try to execute the query
try
{
var numberOfRowsEffected = 0;
//Check for the existence of the date string that was provided.
oleDbCommand.CommandText = "SELECT ID FROM WeekEnding WHERE EndOfWeekDate = @dateString";
oleDbCommand.Parameters.AddWithValue("@dateString", dateString);
oleDbCommand.Connection = _oleDbConnection;
_oleDbConnection.Open();
//Execute the SELECT statement and retrieve the row(s) effected.
var reader = oleDbCommand.ExecuteReader();
var recordIndex = 0;
while (reader != null && reader.Read())
{
if (reader[recordIndex].ToString() != "")
{
numberOfRowsEffected++;
}
recordIndex++;
}
reader?.Close();
//IF one row was affected, then return with "True", since the value is already there.
if (numberOfRowsEffected == 1)
{
//Success! Without even lifting a finger, how nice.
return true;
}
//ELSE IF more then one row was effected, then that means we have redundancy...
else if (numberOfRowsEffected > 1)
{
oleDbCommand.CommandText = "DELETE FROM WeekEnding WHERE EndOfWeekDate = @dateString";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("@dateString", dateString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected > 1)
{
//Deletion of extra dates has completed successfully so add in the provided date string.
oleDbCommand.CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES(@dateString)";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("@dateString", dateString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected != 1)
{
//?
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error has occurred attempting to insert the date " + dateString + " into the week ending table.");
}
}
}
else if (numberOfRowsEffected == 0)
{
oleDbCommand.CommandText = "INSERT INTO WeekEnding(EndOfWeekDate) VALUES (?)";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("dateString", dateString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected == 0)
{
//?
_logConsole.WriteToLog(FrmLogConsole.Level.Debug,
"An error has occurred attempting to insert the date " + dateString +
" into the week ending table.");
}
else
{
insertWasSuccessful = true;
}
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the Week Ending table.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message + "\n" + e.StackTrace);
}
finally
{
//Make certain that the connection is closed before returning.
_oleDbConnection.Close();
}
return insertWasSuccessful;
}
public bool RedundantlessInsertIntoComments(string comments, string dateIdString)
{
//Again, assume a failed operation so there are no false positives.
var insertWasSuccessful = false;
var storedComment = "";
//Set up the command object, SQL command string and parameters.
var oleDbCommand = new OleDbCommand {Connection = _oleDbConnection};
//Try to execute the query
try
{
int numberOfRowsEffected;
//IF one row was affected, then check to see if the comments are the same.
//Check to see if the comments already exist.
//TODO: Perform a little Reg-ex magic to determine if the comments are just different due to spaces or small word changes.
oleDbCommand.CommandText = "SELECT Comment FROM Comment WHERE FK_DateID = dateID";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("dateID", dateIdString);
_oleDbConnection.Open();
//OpenConnection();
var reader = oleDbCommand.ExecuteReader();
var recordIndex = 0;
while (reader != null && reader.Read())
{
if (recordIndex == 0)
{
storedComment = reader[0].ToString();
}
else
{
storedComment += reader[0].ToString();
}
if (storedComment != "")
{
recordIndex++;
}
}
reader?.Close();
//IF there is a comment that has the same date then check to see if it is the same as the one entered.
if (recordIndex == 1)
{
if (storedComment == comments)
{
//The comments match so return true.
return true;
}
else
{
//ELSE the comments are different, therefore the entry needs to be updated.
oleDbCommand.CommandText = "UPDATE Comment SET Comment.Comment = ? WHERE [Comment.FK_DateID] = ?;";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("comment", storedComment + "\r\n" + comments);
oleDbCommand.Parameters.AddWithValue("dateID", dateIdString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected == 1)
{
//Update was successful, so return true.
return true;
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error has occurred trying to update a comment with the date ID of " + dateIdString + ".");
return false;
}
}
}
else if (recordIndex > 1)
{
//ELSE IF more then one record was found with the same date ID, then clear the redundancy and rewrite to the database.
numberOfRowsEffected = 0;
oleDbCommand.CommandText = "DELETE FROM Comment WHERE FK_DateID = dateID";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("dateID", dateIdString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected > 1)
{
oleDbCommand.CommandText = "INSERT INTO Comment(Comment, FK_DateID) VALUES(comments, dateID)";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("comments", storedComment + "\r\n" + comments);
oleDbCommand.Parameters.AddWithValue("dateID", dateIdString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected == 1)
{
return true;
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to insert a new comment after attempting to delete redundant entries.");
return false;
}
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to delete redundant comments.");
return false;
}
}
//Reset the number effected so there is no confusion.
numberOfRowsEffected = 0;
//Now execute the INSERT statement since no redundancy was found.
//The comments are not found to be used in the database anywhere, nor the date ID so add a brand new row.
oleDbCommand.CommandText = "INSERT INTO Comment(Comment, FK_DateID) VALUES (comments, dateID)";
oleDbCommand.Parameters.Clear();
oleDbCommand.Parameters.AddWithValue("comments", comments);
oleDbCommand.Parameters.AddWithValue("dateID", dateIdString);
numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected == 1)
{
insertWasSuccessful = true;
}
else if (numberOfRowsEffected == 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to insert new comments into the Comment table.");
insertWasSuccessful = false;
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the Comment table.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "Message " + e.Message);
}
finally
{
//Make certain that the connection is closed before returning.
_oleDbConnection.Close();
}
return insertWasSuccessful;
}
/// <summary>
/// Inserts the data table provided into the APC table.
/// The rows of the table must match the physical layout of the
/// APC table. The last column in the table, just before the foreign keys
/// is RowAttribute and row position. Then its Fk_AdItem, FK_GroupID and FK_DateID (always the last foreign key).
/// </summary>
/// <param name="parameters"></param>
/// <returns>A list which contains the row numbers of all added rows.</returns>
public List<int> RedundantlessInsertIntoApc(DataTable parameters)
{
//Check to see if the DataTable is empty, and if it is one return -1 as the error.
if (parameters == null || parameters.Rows.Count == 0)
{
//Create new List<int> variable and assign it to 0.
var noRowsAdded = new List<int> {0};
return noRowsAdded;
}
_oleDbConnection.Open();
var rowsAdded = new List<int>();
var rowNumber = 0;
//DataTable's structure will reflect the APC database table structure.
foreach (DataRow row in parameters.Rows)
{
var adItemId = ReturnAdItemIdFromAdItemString(row[18].ToString());
var dateId = row[20].ToString(); //The nineteenth (19th) entry is the dateID field.
var rowsEffected = 0;
if (adItemId == "0")
{
//IF the ad item could not be found in the database, add it in.
adItemId = InsertAdItem(row[17].ToString());
//IF the ID is still zero (0), then something went wrong...
if (adItemId == "0")
{
//Add an error code to the end of the array; something went wrong adding the new item to the database.
rowsAdded.Add(0);
return rowsAdded;
}
}
if (!DoesEntryExist(adItemId, dateId))
{
//IF the ad item isn't in the APC table with the specified date, then add it to the database.
var oleDbCommand = new OleDbCommand
{
CommandText =
"INSERT INTO APC(ProjectionSold, ProjectionSalePrice, ProjectionTotalSales, ProjectionCost, ProjectionProfitReturn, ProjectionTotalProfitReturn, BeginingInventory, Received, TotalInventory, EndingInventory, ActualSold, ActualSalePrice, ActualTotalSales, ActualCost, ActualProfitReturn, ActualTotalProfitReturn, RowAttribute, RowPosition, FK_AdItemID, FK_GroupID, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
};
oleDbCommand.Parameters.AddWithValue("prSold", row[0]);
oleDbCommand.Parameters.AddWithValue("prSalesPrice", row[1]);
oleDbCommand.Parameters.AddWithValue("prTotalSales", row[2]);
oleDbCommand.Parameters.AddWithValue("prCost", row[3]);
oleDbCommand.Parameters.AddWithValue("prProfitReturn", row[4]);
oleDbCommand.Parameters.AddWithValue("prTotalProfitReturn", row[5]);
oleDbCommand.Parameters.AddWithValue("beginingInv", row[6]);
oleDbCommand.Parameters.AddWithValue("receivedInv", row[7]);
oleDbCommand.Parameters.AddWithValue("totalInv", row[8]);
oleDbCommand.Parameters.AddWithValue("endingInv", row[9]);
oleDbCommand.Parameters.AddWithValue("acSold", row[10]);
oleDbCommand.Parameters.AddWithValue("acSalesPrice", row[11]);
oleDbCommand.Parameters.AddWithValue("acTotalSales", row[12]);
oleDbCommand.Parameters.AddWithValue("acCost", row[13]);
oleDbCommand.Parameters.AddWithValue("acProfitReturn", row[14]);
oleDbCommand.Parameters.AddWithValue("acTotalProfitReturn", row[15]);
oleDbCommand.Parameters.AddWithValue("RowAttribute", row[16]);
oleDbCommand.Parameters.AddWithValue("RowPosition", row[17]);
oleDbCommand.Parameters.AddWithValue("AdItemID", adItemId);
oleDbCommand.Parameters.AddWithValue("GroupID", row[19]);
oleDbCommand.Parameters.AddWithValue("dateID", row[20]);
oleDbCommand.Connection = _oleDbConnection;
try
{
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
}
reader?.Close();
if (rowsEffected == 1)
{
rowsAdded.Add(rowNumber);
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to write a record to the APC table.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
_oleDbConnection.Close();
//Add an error code at the end of array of rows that were added to show an error occurred.
rowsAdded.Add(-1);
return rowsAdded;
}
}
else
{
//Perform an update operation on the row in question.
if (!UpdateRow(adItemId, dateId, row))
{
//IF the update fails, then return with an error appended to the end of the array.
rowsAdded.Add(0);
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to update a record APC table.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "An error occurred trying to update ad item ID " + adItemId + " and dateID " + dateId + ".");
_oleDbConnection.Close();
return rowsAdded;
}
}
rowNumber++;
}
//Close the database connection before returning.
_oleDbConnection.Close();
return rowsAdded;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
/// Checks to see if an ad item exists based on its end of week date.
/// </summary>
/// <param name="adItemId">The ID of the item.</param>
/// <param name="dateId">The ID of the end of week date.</param>
/// <returns>True if the item exists, or false if it doesn't.</returns>
private bool DoesEntryExist(string adItemId, string dateId)
{
var exists = false;
var oleDbCommand = new OleDbCommand();
var rowsEffected = 0;
oleDbCommand.CommandText = "SELECT ID FROM APC WHERE FK_AdItemID = adItemID AND FK_DateID = dateID";
oleDbCommand.Parameters.AddWithValue("adItemID", adItemId);
oleDbCommand.Parameters.AddWithValue("dateID", dateId);
oleDbCommand.Connection = _oleDbConnection;
try
{
oleDbCommand.Transaction = _oleDbConnection.BeginTransaction();
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
}
reader?.Close();
}
catch (OleDbException ex)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to check for the existence of an ad item with the ID of " + adItemId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message);
}
if (rowsEffected == 1)
{
exists = true;
}
else if (rowsEffected > 1)
{
//Throw custom exception, or add a function to correct this issue.
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "A redundant entry has been found with the following values: AdItemID " + adItemId + " and DateID " + dateId + ".");
exists = true;
}
return exists;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
/// This method adds a specified ad item to the database's ad item table.
/// </summary>
/// <param name="adItemName">The name of the ad item.</param>
/// <returns>The ID number of the ad item, or zero (0) on fail.</returns>
private string InsertAdItem(string adItemName)
{
//Remove all nulls from the adItemName and check if it is null.
string cleanedAdItemName = adItemName.Replace(" ", "");
if (adItemName == "")
{
//
//throw new System.ArgumentException("Attempted to insert a null ad item name into the database.");
return "0";
}
else if (cleanedAdItemName.Length == 1)
{
//
//throw new System.ArgumentException("Attempted to insert an ad item name with invalid length.");
return "0";
}
//Record the number of rows affected when the statement is executed, again assume nothing was affected.
var adItemId = "0";
var oleDbCommand = new OleDbCommand
{
CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)",
Connection = _oleDbConnection
};
oleDbCommand.Parameters.AddWithValue("adItem", adItemName);
//Attempt to execute the INSERT SQL statement.
try
{
var rowsEffected = oleDbCommand.ExecuteNonQuery();
//IF one (1) row was affected, then get the ad item's ID and set it to the return value.
if (rowsEffected == 1)
{
//Modify the OleDbCommand object to query the ad item with the highest ID value since that would be the most recent item added.
oleDbCommand.CommandText = "SELECT ID FROM AdItem WHERE ID = (SELECT MAX(AdItem.ID) FROM AdItem)";
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
adItemId = reader[0].ToString();
}
reader?.Close();
}
//ELSE IF more then one (1) row was affected...
else if (rowsEffected > 1)
{
//?
}
//ELSE IF no rows are effected due to an uncaught exception, log it.
else if (rowsEffected == 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to add " + adItemName + " into the database; zero (0) rows affected.");
return "0";
}
}
catch (OleDbException ex)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to add " + adItemName + " to the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message);
}
return adItemId;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
/// Returns the ad item ID from the ad item's name.
/// </summary>
/// <returns>The ID of the specified item.</returns>
private string ReturnAdItemIdFromAdItemString(string adItemName)
{
var id = "0";
double parsedName;
//Clear all invalid characters and check if its a null entry.
if (adItemName.Replace(" " , "") == "")
{
return id;
}
if (double.TryParse(adItemName, out parsedName))
{
//A number has been found so error out.
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Ad item name cannot be only numeric characters.");
return id;
}
var oleDbCommand = new OleDbCommand {CommandText = "SELECT ID FROM AdItem WHERE UCASE(AdItem.AdItem) = UCASE(adItemName)"};
oleDbCommand.Parameters.AddWithValue("adItemName", adItemName);
oleDbCommand.Connection = _oleDbConnection;
try
{
var adItemId = "";
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
adItemId = reader[0].ToString();
}
if (reader != null) reader.Close();
//Grab the ad item's ID.
if (adItemId != "0")
{
id = adItemId;
}
else
{
//Return 0 as the ad item doesn't exist.
return id;
}
}
catch (OleDbException ex)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "An error occurred trying to obtain the ad item ID for " + adItemName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message);
}
return id;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
/// Performs an update operation on the row with matching IDs in the ad item and date ID columns.
/// This is to be called when an ad item already exists and simply needs updating with new values.
/// </summary>
/// <param name="adItemId"></param>
/// <param name="dateId"></param>
/// <param name="parameters"></param>
/// <returns></returns>
private bool UpdateRow(string adItemId, string dateId, DataRow parameters)
{
var updateSuccessful = false;
var oleDbCommand = new OleDbCommand
{
CommandText =
"UPDATE APC SET ProjectionSold = ?, ProjectionSalePrice = ?, ProjectionTotalSales = ?, ProjectionCost = ?, ProjectionProfitReturn = ?, ProjectionTotalProfitReturn = ?, BeginingInventory = ?, Received = ?, TotalInventory = ?, EndingInventory = ?, ActualSold = ?, ActualSalePrice = ?, ActualTotalSales = ?, ActualCost = ?, ActualProfitReturn = ?, ActualTotalProfitReturn = ?, RowAttribute = ?, RowPosition = ?, FK_GroupID = ? WHERE FK_DateID = ? AND FK_AdItemID = ?"
};
oleDbCommand.Parameters.AddWithValue("prSold", parameters[0]);
oleDbCommand.Parameters.AddWithValue("prSalesPrice", parameters[1]);
oleDbCommand.Parameters.AddWithValue("prTotalSales", parameters[2]);
oleDbCommand.Parameters.AddWithValue("prCost", parameters[3]);
oleDbCommand.Parameters.AddWithValue("prProfitReturn", parameters[4]);
oleDbCommand.Parameters.AddWithValue("prTotalProfitReturn", parameters[5]);
oleDbCommand.Parameters.AddWithValue("beginingInv", parameters[6]);
oleDbCommand.Parameters.AddWithValue("receivedInv", parameters[7]);
oleDbCommand.Parameters.AddWithValue("totalInv", parameters[8]);
oleDbCommand.Parameters.AddWithValue("endingInv", parameters[9]);
oleDbCommand.Parameters.AddWithValue("acSold", parameters[10]);
oleDbCommand.Parameters.AddWithValue("acSalesPrice", parameters[11]);
oleDbCommand.Parameters.AddWithValue("acTotalSales", parameters[12]);
oleDbCommand.Parameters.AddWithValue("acCost", parameters[13]);
oleDbCommand.Parameters.AddWithValue("acProfitReturn", parameters[14]);
oleDbCommand.Parameters.AddWithValue("acTotalProfitReturn", parameters[15]);
oleDbCommand.Parameters.AddWithValue("RowAttribute", parameters[16]);
oleDbCommand.Parameters.AddWithValue("RowPosition", parameters[17]);
oleDbCommand.Parameters.AddWithValue("groupID", parameters[19]);
oleDbCommand.Parameters.AddWithValue("dateID", parameters[20]);
oleDbCommand.Parameters.AddWithValue("adItemID", adItemId);
oleDbCommand.Connection = _oleDbConnection;
try
{
var numberOfRowsEffected = oleDbCommand.ExecuteNonQuery();
if (numberOfRowsEffected == 1)
{
updateSuccessful = true;
}
else if (numberOfRowsEffected > 1) //?
{
_logConsole.WriteToLog(FrmLogConsole.Level.Warning, "Redundancy found: Ad item ID " + parameters[0] + " (" + parameters[17] + ") and date ID " + parameters[18] + ".");
updateSuccessful = true;
}
_logConsole.WriteToLog(FrmLogConsole.Level.Info, "Affected " + numberOfRowsEffected + " updating the ad item " + parameters[17] + ".");
}
catch (OleDbException ex)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update ad item with the ID of " + parameters[0] + " (" + parameters[17] + ") and a date ID of " + parameters[18] + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message);
return false;
}
return updateSuccessful;
}
/// <summary>
///
/// </summary>
/// <param name="parameters">A copy of the Supplier DataGridView table.</param>
/// <returns></returns>
public List<int> RedundantlessInsertIntoInvoice(DataTable parameters)
{
//Create an array that hold the indexes of all the rows that were successfully written to the database.
var rowsAdded = new List<int>();
var supplierId = "";
//Setup object for each of the three (3) tasks that need to be performed.
//Checking for the ID of a particular supplier, by name.
var supplierQueryCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM Supplier WHERE SupplierName = ?",
Connection = _oleDbConnection
};
//Grabbing the ID of the invoice by the invoice number and the supplier's ID.
var invoiceCheckCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM Invoice WHERE InvoiceNumber = ? AND FK_Supplier = ?",
Connection = _oleDbConnection
};
//Inserting a new record into the Invoice table.
var insertNewInvoice = new OleDbCommand
{
CommandText =
"INSERT INTO Invoice (InvoiceDate, InvoiceNumber, InvoiceNetAmountAtCost, InvoiceNetAmount, InvoiceNote, FK_Supplier, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?)",
Connection = _oleDbConnection
};
_oleDbConnection.Open();
foreach (DataRow row in parameters.Rows)
{
var itemCount = 0;
var index = 0;
foreach (var obj in row.ItemArray)
{
//Check for null objects, row size is 8 on creation for some reason.
if (index < 7)
{
if ((string)obj != "")
{
itemCount++;
}
else
{
row[index] = 0;
}
}
index++;
}
if (itemCount < 2)
{
break;
}
var recordCount = 0;
try
{
//Check for the existence of the supplier to be written.
supplierQueryCommand.Parameters.Clear();
supplierQueryCommand.Parameters.AddWithValue("SupplierName", row[1]);
var reader = supplierQueryCommand.ExecuteReader();
//Read in the value(s) from the database.
while (reader != null && reader.Read())
{
if (recordCount == 0)
{
supplierId = reader[0].ToString();
}
recordCount++;
}
if(reader != null) reader.Close();
//IF no records were pulled, then ad the supplier's name into the database and pull the ID for the new entry.
if (recordCount == 0)
{
supplierId = InsertSupplier(row[1].ToString());
if (supplierId != "0")
{
recordCount = 1;
}
//ELSE IF the supplier ID wasn't set, indicting an error, so break out of the loop and add zero (0) to the end of the rows effected array.
else
{
rowsAdded.Add(0);
break;
}
}
//IF the supplier exists in the database, then check for the presence of the supplier and the supplied invoice number.
if (recordCount == 1)
{
invoiceCheckCommand.Parameters.Clear();
invoiceCheckCommand.Parameters.AddWithValue("InvoiceNumber", row[2]);
invoiceCheckCommand.Parameters.AddWithValue("SupplierID", supplierId);
reader = invoiceCheckCommand.ExecuteReader();
recordCount = 0;
while (reader != null && reader.Read())
{
recordCount++;
}
if (reader != null) reader.Close();
//IF the entry does exist, then update it with the new information provided.
if (recordCount == 1)
{
//Call the update function and attempt to update the information.
if (!UpdateInvoice(row, supplierId))
{
//IF the update failed log the failure, add in a failure at the row that failed, and break out.
//LOGGING GOES HERE
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update the record for " + row[1] + ".");
rowsAdded.Add(0);
break;
}
}
else if (recordCount > 1)
{
//TODO: Clean up the database's redundant entries.
}
else if (recordCount == 0)
{
//ELSE IF no records were found, then insert the new invoice into the Invoice table.
insertNewInvoice.Parameters.Clear();
insertNewInvoice.Parameters.AddWithValue("InvoiceDate", row[0]);
insertNewInvoice.Parameters.AddWithValue("InvoiceNumber", row[2]);
insertNewInvoice.Parameters.AddWithValue("InvoiceNetAmountAtCost", row[3]);
insertNewInvoice.Parameters.AddWithValue("InvoiceNetAmount", row[4]);
insertNewInvoice.Parameters.AddWithValue("InvoiceNote", row[5]);
insertNewInvoice.Parameters.AddWithValue("SupplierID", supplierId);
insertNewInvoice.Parameters.AddWithValue("DateID", row[6]);
var rowsEffected = insertNewInvoice.ExecuteNonQuery();
if (rowsEffected == 1) continue;
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write new invoice to the database for supplier " + row[1] + " ID of " + supplierId + ".");
rowsAdded.Add(0);
break;
}
}
//ELSE IF more then one record was found, clean up the redundancy.
else if (recordCount > 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Info, "Redundancy found in the invoices table with supplier " + row[1] + ".");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to write supplier " + row[1] + " into the invoice table.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
_oleDbConnection.Close();
break;
}
}
_oleDbConnection.Close();
return rowsAdded;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
///
/// </summary>
/// <param name="supplierName"></param>
/// <returns></returns>
private string InsertSupplier(string supplierName)
{
double doubleParsedValue;
if (supplierName == "")
{
return "0";
}
if(double.TryParse(supplierName, out doubleParsedValue))
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Supplier name cannot be only numeric characters.");
return "0";
}
var supplierNameId = "0";
var oleDbCommand = new OleDbCommand {CommandText = "INSERT INTO Supplier (SupplierName) VALUES (?)"};
oleDbCommand.Parameters.AddWithValue("SupplierName", supplierName);
oleDbCommand.Connection = _oleDbConnection;
try
{
var rowsEffected = oleDbCommand.ExecuteNonQuery();
if (rowsEffected == 1)
{
oleDbCommand.CommandText = "SELECT ID FROM Supplier WHERE ID = (SELECT MAX(Supplier.ID) FROM Supplier)";
var reader = oleDbCommand.ExecuteReader();
while (reader != null && reader.Read())
{
supplierNameId = reader[0].ToString();
}
if (reader != null) reader.Close();
}
else if (rowsEffected > 1)
{
//TODO: Clean up the database.
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to write supplier name " + supplierName + " to the suppliers table.");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Critical, "Failed to write supplier name " + supplierName + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
return supplierNameId;
}
/// <summary>
/// Infrastructure for the DatabaseWriter class, not meant to be used with external code; expects an open connection when called.
///
/// </summary>
/// <param name="invoiceField"></param>
/// <param name="supplierId"></param>
/// <returns></returns>
private bool UpdateInvoice(DataRow invoiceField, string supplierId)
{
var updateSuccessful = false;
var oleDbCommand = new OleDbCommand
{
CommandText =
"UPDATE Invoice SET InvoiceDate = ?, InvoiceNetAmountAtCost = ?, InvoiceNetAmount = ?, InvoiceNote = ? WHERE InvoiceNumber = ? AND FK_Supplier = ? AND FK_DateID = ?"
};
oleDbCommand.Parameters.AddWithValue("InvoiceDate", invoiceField[0]);
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmountAtCost", invoiceField[3]);
oleDbCommand.Parameters.AddWithValue("InvoiceNetAmount", invoiceField[4]);
oleDbCommand.Parameters.AddWithValue("InvoiceNote", invoiceField[5]);
oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceField[2]);
oleDbCommand.Parameters.AddWithValue("SupplierID", supplierId);
oleDbCommand.Parameters.AddWithValue("DateID", invoiceField[6]);
oleDbCommand.Connection = _oleDbConnection;
try
{
var rowsEffected = oleDbCommand.ExecuteNonQuery();
if (rowsEffected == 1)
{
updateSuccessful = true;
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update record with invoice number " + invoiceField[2] + " for " + invoiceField[1] + ".");
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to update invoice record invoice number " + invoiceField[2] + " for supplier " + invoiceField[1] + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
return updateSuccessful;
}
/// <summary>
///
/// </summary>
/// <param name="parameters"></param>
/// <returns></returns>
public int RedundantlessInsertIntoWeeklySales(DataRow parameters)
{
var rowsEffected = 0;
var recordsRead = 0;
//Object to check for the presence of an entry with the supplied date.
var weekEndingDateCheck = new OleDbCommand
{
CommandText = "SELECT ID FROM WeeklySales WHERE FK_DateID = ?"
};
weekEndingDateCheck.Parameters.AddWithValue("DateID", parameters[8]);
weekEndingDateCheck.Connection = _oleDbConnection;
//Object to update a field with the date supplied, assuming an entry was found with the previous object.
var updateWeeklySales = new OleDbCommand
{
CommandText =
"UPDATE WeeklySales SET Sunday = ?, Monday = ?, Tuesday = ?, Wednesday = ?, Thursday = ?, Friday = ?, Saturday = ?, TotalSales = ? WHERE FK_DateID = ?"
};
updateWeeklySales.Parameters.AddWithValue("Sunday", parameters[0]);
updateWeeklySales.Parameters.AddWithValue("Monday", parameters[1]);
updateWeeklySales.Parameters.AddWithValue("Tuesday", parameters[2]);
updateWeeklySales.Parameters.AddWithValue("Wednesday", parameters[3]);
updateWeeklySales.Parameters.AddWithValue("Thursday", parameters[4]);
updateWeeklySales.Parameters.AddWithValue("Friday", parameters[5]);
updateWeeklySales.Parameters.AddWithValue("Saturday", parameters[6]);
updateWeeklySales.Parameters.AddWithValue("TotalSales", parameters[7]);
updateWeeklySales.Parameters.AddWithValue("DateID", parameters[8]);
updateWeeklySales.Connection = _oleDbConnection;
//Object to insert a new field into the database if no entry is present.
var insertWeeklySales = new OleDbCommand
{
CommandText =
"INSERT INTO WeeklySales (Sunday, Monday, Tuesday, Wednesday, Thursday, Friday, Saturday, TotalSales, FK_DateID) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
};
insertWeeklySales.Parameters.AddWithValue("Sunday", parameters[0]);
insertWeeklySales.Parameters.AddWithValue("Monday", parameters[1]);
insertWeeklySales.Parameters.AddWithValue("Tuesday", parameters[2]);
insertWeeklySales.Parameters.AddWithValue("Wednesday", parameters[3]);
insertWeeklySales.Parameters.AddWithValue("Thursday", parameters[4]);
insertWeeklySales.Parameters.AddWithValue("Friday", parameters[5]);
insertWeeklySales.Parameters.AddWithValue("Saturday", parameters[6]);
insertWeeklySales.Parameters.AddWithValue("TotalSales", parameters[7]);
insertWeeklySales.Parameters.AddWithValue("DateID", parameters[8]);
insertWeeklySales.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
//Execute the select statement to check for the presence of an entry with the supplied date (parameters[8]).
var reader = weekEndingDateCheck.ExecuteReader();
while (reader != null && reader.Read())
{
recordsRead++;
}
if (reader != null) reader.Close();
//IF there are no records with the date ID then add the current sales into the database.
if (recordsRead == 0)
{
rowsEffected = insertWeeklySales.ExecuteNonQuery();
}
//ELSE IF one already exists, then update it with the information provided.
else if (recordsRead == 1)
{
rowsEffected = updateWeeklySales.ExecuteNonQuery();
}
//ELSE IF more then one entry is detected, remove all redundant entries and insert the current sales into the database.
else if (recordsRead > 1)
{
//TODO: clean up the redundant entries.
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"An error has occurred trying to write the weekly sales to the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return rowsEffected;
}
public int RedundantlessInsertIntoGroupCategory(string groupName)
{
//
var rowsEffected = 0;
//Setup an object to check for the existence of the group name to be added.
var categoryDescCheckQueryCommand = new OleDbCommand
{
CommandText = "SELECT ID FROM GroupCategory WHERE GroupDescription = ?"
};
categoryDescCheckQueryCommand.Parameters.AddWithValue("GroupName", groupName);
categoryDescCheckQueryCommand.Connection = _oleDbConnection;
//Setting up an object to insert a new ad special keyword.
var insertNewCategoryDesc = new OleDbCommand
{
CommandText = "INSERT INTO GroupCategory (GroupDescription) VALUES (?)"
};
insertNewCategoryDesc.Parameters.AddWithValue("GroupName", groupName);
insertNewCategoryDesc.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
var reader = categoryDescCheckQueryCommand.ExecuteReader();
while (reader != null && reader.Read())
{
rowsEffected++;
}
if (reader != null) reader.Close();
if (rowsEffected == 0)
{
rowsEffected = insertNewCategoryDesc.ExecuteNonQuery();
if (rowsEffected == 0)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"An error has occurred trying to insert " + groupName + " into the database.");
}
}
}
catch (OleDbException ex)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"An error has occurred trying to write a new ad special key word to the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, ex.Message);
}
finally
{
_oleDbConnection.Close();
}
return rowsEffected;
}
public int RemoveAdSpecialMember(string adSpecialName)
{
var rowsEffected = 0;
var oleDbCommand = new OleDbCommand()
{
CommandText = "DELETE FROM GroupCategory WHERE GroupDescription = ?"
};
oleDbCommand.Parameters.AddWithValue("AdSpecialName", adSpecialName);
oleDbCommand.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
rowsEffected = oleDbCommand.ExecuteNonQuery();
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error,
"Failed to delete the ad special " + adSpecialName + " from the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return rowsEffected;
}
public int RemoveRecord(string adItemId, string dateId)
{
var recordsDeleted = 0;
var deleteCommand = new OleDbCommand
{
CommandText = "DELETE FROM APC WHERE FK_AdItemID = ? AND FK_DateID = ?"
};
deleteCommand.Parameters.AddWithValue("AdItemID", adItemId);
deleteCommand.Parameters.AddWithValue("DateID", dateId);
deleteCommand.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
recordsDeleted = deleteCommand.ExecuteNonQuery();
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the record with an ad item ID of " + adItemId + " and a date ID of " + dateId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return recordsDeleted;
}
public int RemoveInvoice(string invoiceNumber, string dateId)
{
var recordsAffected = 0;
var oleDbCommand = new OleDbCommand()
{
CommandText = "DELETE FROM Invoice WHERE InvoiceNumber = ? AND FK_DateID = ?"
};
oleDbCommand.Parameters.AddWithValue("InvoiceNumber", invoiceNumber);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
recordsAffected = oleDbCommand.ExecuteNonQuery();
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete invoice number " + invoiceNumber + " with the date ID of " + dateId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return recordsAffected;
}
/// <summary>
/// Removes all records by the date ID passed in, and also removes
/// the year's entry from the WeekEnding table.
/// </summary>
/// <param name="dateId">The ID of the date to be purged.</param>
/// <returns>The number of records cleared from the database.</returns>
public int RemoveAllEntriesAndYearById(string dateId)
{
var recordsRemoved = 0;
//Object to clear the APC records associated with the date ID.
var clearApCommand = new OleDbCommand()
{
CommandText = "DELETE FROM APC WHERE FK_DateID = ?"
};
clearApCommand.Parameters.AddWithValue("DateID", dateId);
clearApCommand.Connection = _oleDbConnection;
//Object to clear comments associated with the date ID.
var clearCommentsCommand = new OleDbCommand()
{
CommandText = "DELETE FROM Comment WHERE FK_DateID = ?"
};
clearCommentsCommand.Parameters.AddWithValue("DateID", dateId);
clearCommentsCommand.Connection = _oleDbConnection;
//Object to clear the invoices associated with the date ID.
var clearInvoicesCommand = new OleDbCommand()
{
CommandText = "DELETE FROM Invoice WHERE FK_DateID = ?"
};
clearInvoicesCommand.Parameters.AddWithValue("DateID", dateId);
clearInvoicesCommand.Connection = _oleDbConnection;
//Object to clear the weekly sales associated with the date ID.
var clearWeeklySalesCommand = new OleDbCommand()
{
CommandText = "DELETE FROM WeeklySales WHERE FK_DateID = ?"
};
clearWeeklySalesCommand.Parameters.AddWithValue("DateID", dateId);
clearWeeklySalesCommand.Connection = _oleDbConnection;
//Object to clear the date associated with the ID passed in.
var clearEndOfWeekDateCommand = new OleDbCommand()
{
CommandText = "DELETE FROM WeekEnding WHERE ID = ?"
};
clearEndOfWeekDateCommand.Parameters.AddWithValue("DateID", dateId);
clearEndOfWeekDateCommand.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
recordsRemoved += clearApCommand.ExecuteNonQuery();
recordsRemoved += clearCommentsCommand.ExecuteNonQuery();
recordsRemoved += clearInvoicesCommand.ExecuteNonQuery();
recordsRemoved += clearWeeklySalesCommand.ExecuteNonQuery();
recordsRemoved += clearEndOfWeekDateCommand.ExecuteNonQuery();
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "And error has occurred attempting to delete all records associated with the date ID of " + dateId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return recordsRemoved;
}
/// <summary>
/// Updates the comments stored in a particular date.
/// TODO: Fix this bug...
/// IF the delete command deletes more then one row it returns 0.
/// </summary>
/// <param name="comment"></param>
/// <param name="dateId"></param>
/// <returns>Returns true if the row is deleted and false if a row fails to be deleted.</returns>
public bool UpdateCommentsByDateId(string comment, string dateId)
{
var wasSuccessful = false;
var oleDbCommand = new OleDbCommand()
{
CommandText = "UPDATE Comment SET Comment.Comment = ? WHERE FK_DateID = ?"
};
oleDbCommand.Parameters.AddWithValue("Comment", comment);
oleDbCommand.Parameters.AddWithValue("DateID", dateId);
oleDbCommand.Connection = _oleDbConnection;
try
{
//IF the delete command deletes more then one row it returns 0.
_oleDbConnection.Open();
var recordsEffected = oleDbCommand.ExecuteNonQuery();
if (recordsEffected == 1)
{
wasSuccessful = true;
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "And error has occurred attempting to update the comments for the date ID of " + dateId + ".");
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return wasSuccessful;
}
public bool RemoveAdItem(string adItemName)
{
var success = false;
var oleDbCommand = new OleDbCommand
{
CommandText = "DELETE FROM AdItem WHERE AdItem = ?"
};
oleDbCommand.Parameters.AddWithValue("AdItemName", adItemName);
oleDbCommand.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
var rowsEffected = oleDbCommand.ExecuteNonQuery();
if(rowsEffected == 1)
{
success = true;
}
else if(rowsEffected > 1)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Info, "Removed redundant entry " + adItemName + " from the database successfully.");
success = true;
}
else
{
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to delete the ad item " + adItemName + " from the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return success;
}
public bool AddNewItem(string adItemName)
{
var success = false;
var oleDbCommand = new OleDbCommand
{
CommandText = "INSERT INTO AdItem (AdItem) VALUES (?)"
};
oleDbCommand.Parameters.AddWithValue("AdItemName", adItemName);
oleDbCommand.Connection = _oleDbConnection;
var redundantancyCheck = new OleDbCommand
{
CommandText = "SELECT AdItem FROM AdItem WHERE AdItem = ?"
};
redundantancyCheck.Parameters.AddWithValue("AdItemName", adItemName);
redundantancyCheck.Connection = _oleDbConnection;
try
{
_oleDbConnection.Open();
using(var reader = redundantancyCheck.ExecuteReader())
{
var rows = 0;
while(reader != null && reader.Read())
{
rows++;
}
if(rows == 0)
{
var rowsEffected = oleDbCommand.ExecuteNonQuery();
if (rowsEffected == 1)
{
success = true;
}
else
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to insert new ad item " + adItemName + ".");
}
}
else
{
success = true;
_logConsole.WriteToLog(FrmLogConsole.Level.Debug, "Ad Item " + adItemName + " found with " + rows + " row(s).");
}
}
}
catch (OleDbException e)
{
_logConsole.WriteToLog(FrmLogConsole.Level.Error, "Failed to add the new ad item " + adItemName + " to the database.");
_logConsole.WriteToLog(FrmLogConsole.Level.Error, e.Message);
}
finally
{
_oleDbConnection.Close();
}
return success;
}
}
}
Reference in New Issue View Git Blame Copy Permalink