using Sarand.Net.Standard.Dbas.Data; using Sarand.Net.Standard.Base.App; using Sarand.Net.Standard.Base.Bus; using Sarand.Net.Standard.Base.Core; using Sarand.Net.Standard.Base.Dbas; using Saxonite.Base.App; using Saxonite.Net.Standard.Dbas.Bus; using Saxonite.Net.Standard.Dbas.Internal; using Saxonite.Net.Standard.Base.App; using Saxonite.Net.Standard.Base.Bus; using System; using System.Collections.Generic; using System.Data.Common; using System.Text; using Sarand.Net.Standard.Base.Utils; using System.Linq; namespace Saxonite.Net.Standard.Dbas.Mgr { //======================================================================= partial class SaxReferenceMgr_Dbas { //******************************************************************* // Reference Mgr - Sport //******************************************************************* // Utilities. private List GetLogProperties(SaxSport sport) { return new List() { new StringPair("Id", SysId.ToString(sport.Id)), new StringPair("Name", sport.Name), new StringPair("Status", sport.StatusCode) }; } //------------------------------------------------------------------- // Create item. public override SaxSport CreateSport() { ClearErrorState(); return new SaxSport_Dbas(CoreDatabase, null, 0); } private SaxSport_Dbas CreateSport(Sport_Db dbSport) { ClearErrorState(); SaxSport_Dbas sport = new SaxSport_Dbas(CoreDatabase, new SysId(dbSport._Id), (UInt16)dbSport._Flags); PopulateFrom(dbSport, sport); return sport; } //------------------------------------------------------------------- // Get item. public override SaxSport GetSport(SaxSport.Params prm) { ClearErrorState(); return GetSport(GetSportQueryFilter(prm).Concat(" And ", "(", ")")); } private SaxSport GetSport(String filter) { ClearErrorState(); long count = GetSportCount(filter); if (count == 0) return null; if (count != 1) { SetErrorState("Multiple items found"); return null; } SaxSport sport = null; // Query data. using (var dbConnection = CoreDatabase.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); Sport_Db dbSport = new Sport_Db(CoreDbInfo); dbSport.PopulateFrom(dbCommand, aliasSport, filter); sport = CreateSport(dbSport); } catch (Exception exc) { SetErrorState("Database query exception"); SaLogger.Warn(GetType().Name + ".GetSport\n\tQuery: " + dbCommand.CommandText + "\n\t" + ExceptionUtil.GetLogMessage(exc)); } } return sport; } //------------------------------------------------------------------- // Validate item. public override bool IsValidSportData(SaxSport.Data data, SaxSport.ErrField errField) { ClearErrorState(); if (!base.IsValidSportData(data, errField)) return false; return true; } //------------------------------------------------------------------- // Insert item. public override bool InsertSport(SaxSport sport, DbUpdateInfo dbUpdateInfo) { String fn = GetType().Name + ".InsertSport"; ClearErrorState(); if (!IsValidSport(sport)) return false; if (SysId.IsValid(sport.Id)) return SetErrorState(ErrorMessage.ValiditemId); using (var dbConnection = CoreDatabase.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); Sport_Db dbSport = new Sport_Db(CoreDbInfo); PopulateTo(dbSport, sport, dbUpdateInfo); if (Sport_Db.FieldsNonId.Contains("Id")) { // Generate next Id. // ToDo dbSport._Id = CoreDatabase.GetNextIdFromTable("Sport"); } dbSport.ExecuteInsertCommand(dbCommand); sport.Id = new SysId(dbSport._Id); sport.Changed = false; if (DebugMode) SaLogger.Debug(fn + " Inserted. " + GetLogProperties(sport).Concat(": ").Concat("", "\n\t")); } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); } //------------------------------------------------------------------- // Update item. public override bool UpdateSport(SaxSport sport, DbUpdateInfo dbUpdateInfo) { String fn = GetType().Name + ".UpdateSport"; ClearErrorState(); if (!IsValidSport(sport)) return false; if (!SysId.IsValid(sport.Id)) return SetErrorState(ErrorMessage.InvalidItemId); if (!sport.Changed) { if (DebugMode) SaLogger.Debug(fn + " Data not changed. " + GetLogProperties(sport).Concat(": ").Concat("", "\n\t")); return true; } using (var dbConnection = CoreDatabase.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { // Retrieve item. dbConnection.Open(); Sport_Db dbSport = new Sport_Db(CoreDbInfo); dbSport.PopulateFrom(dbCommand, aliasSport, "Id=" + SysId.ToString(sport.Id)); // ToDo SaxUpdateLogItemMonitor_Sport updateLogMonitor = new SaxUpdateLogItemMonitor_Sport(SessionContext, CreateSport(dbSport), dbUpdateInfo); // Update item. PopulateTo(dbSport, sport, dbUpdateInfo); dbSport.ExecuteUpdateCommand(dbCommand); sport.Changed = false; if (DebugMode) SaLogger.Debug(fn + " Updated. " + GetLogProperties(sport).Concat(": ").Concat("", "\n\t")); // Record updates. // ToDo updateLogMonitor.RecordUpdatedValues(sport); // ToDo updateLogMonitor.LogUpdates(); } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); } //------------------------------------------------------------------- // Delete item. public override bool SportCanBeDeleted(SaxSport sport) { ClearErrorState(); if (!base.SportCanBeDeleted(sport)) return false; return true; } public override bool DeleteSport(SaxSport sport, DbUpdateInfo dbUpdateInfo) { String fn = GetType().Name + ".DeleteSport"; ClearErrorState(); if (!SportCanBeDeleted(sport)) return false; // Sports are logically deleted by changing the status. sport.Status = SaStatus.Deleted; return UpdateSport(sport, dbUpdateInfo); /* * Physical deletion. using (var dbConnection = CoreDatabase.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { // Retrieve item. dbConnection.Open(); Sport_Db dbSport = new Sport_Db(CoreDbInfo); dbSport.PopulateFrom(dbCommand, aliasSport, "Id=" + sport.Id.ToString()); // Delete item. dbCommand.CommandType = System.Data.CommandType.Text; dbCommand.CommandText = "DELETE FROM " + SaxDbDfn_Core.GetTableName(SaxDbDfn_Core.TableIdx.Sport) + " WHERE Id=" + SysId.ToString(sport.Id) + ";"; dbCommand.ExecuteNonQuery(); sport.Changed = false; if (DebugMode) SaLogger.Debug(fn + " Deleted. " + GetLogProperties(sport).Concat(": ").Concat("", "\n\t")); } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); */ } //------------------------------------------------------------------- // Copy data properties to and from database. private void PopulateTo(Sport_Db dbSport, SaxSport sport, DbUpdateInfo dbUpdateInfo) { dbSport._Id = SysId.ToInt(sport.Id); dbSport._Name = sport.Name; dbSport._SpecialityLabel = (short)sport.SpecialityLabel; // Common properties. dbSport._Notes = sport.Notes; dbSport._Status = SacsSystem.GetStatusCode(sport.Status); dbSport._Flags = (short)sport.Flags; if (!SysId.IsValid(sport.Id)) { dbSport._CreateOn = DateTime.Now; dbSport._CreateBy = dbUpdateInfo.UserId.ToInt(); dbSport._CreateHost = dbUpdateInfo.Host; } dbSport._UpdateOn = DateTime.Now; dbSport._UpdateBy = dbUpdateInfo.UserId.ToInt(); dbSport._UpdateHost = dbUpdateInfo.Host; } private void PopulateFrom(Sport_Db dbSport, SaxSport sport) { //sport.Id = new SysId(dbSport._Id); sport.Name = dbSport._Name; sport.SpecialityLabel = (Sax.SportSpecialityLabel)dbSport._SpecialityLabel; // Common properties. sport.Notes = dbSport._Notes; sport.Status = SacsSystem.GetStatusForCode(dbSport._Status); sport.SetCreateStamp(dbSport._CreateOn, new SysId(dbSport._CreateBy), dbSport._CreateHost); sport.SetUpdateStamp(dbSport._UpdateOn, new SysId(dbSport._UpdateBy), dbSport._UpdateHost); sport.AcceptChanges(); } //------------------------------------------------------------------- // Item column definitions. private static readonly String aliasSport = "Sprt"; //private static readonly String colSport_AssociatedData_Count = "UsrAct_AD_Count"; private void SetSportColDfn (ColumnDfn col, String caption, int width, SaxDbDfn_Core.ColumnIdx dbCol, ColumnAlignment align = ColumnAlignment.Default, DataValue.DataType dataType = DataValue.DataType.String, String alias = "", String prefix = "") { if (String.IsNullOrEmpty(alias) && SaxDbDfn_Core.GetTableForColumn(dbCol) == SaxDbDfn_Core.TableIdx.Sport) alias = aliasSport; col.Set(caption, width, (int)dbCol, prefix + SaxDbDfn_Core.GetColumnName(dbCol, false), SaxDbDfn_Core.GetColumnNameQual(dbCol, alias), dataType, align); if (dataType == DataValue.DataType.String && dbCol != SaxDbDfn_Core.ColumnIdx.Unknown) col.MaxLength = (int)SaxDbDfn_Core.GetColTextLen(dbCol); } public override ColumnDfn GetSportColumnDfn(SaxSport.Column columnId, string caption = "", int width = 0) { ColumnDfn columnDfn = new ColumnDfn((int)columnId, caption, width); switch (columnId) { //----------------------------------------------------------- // Identification. case SaxSport.Column.Pos: SetSportColDfn(columnDfn, "Pos", 60, SaxDbDfn_Core.ColumnIdx.Unknown, ColumnAlignment.Right); columnDfn.SortMode = ColumnDfn.ColumnSortMode.Off; columnDfn.ReadOnly = true; columnDfn.Resizable = false; break; case SaxSport.Column.Id: SetSportColDfn(columnDfn, "Id", 80, SaxDbDfn_Core.ColumnIdx.Sport_Id, ColumnAlignment.Right, DataValue.DataType.Long); columnDfn.ReadOnly = true; break; //----------------------------------------------------------- // Properties. case SaxSport.Column.Name: SetSportColDfn(columnDfn, "Name", 120, SaxDbDfn_Core.ColumnIdx.Sport_Name); break; case SaxSport.Column.SpecialityLabel: SetSportColDfn(columnDfn, "Speciality label", 80, SaxDbDfn_Core.ColumnIdx.Sport_SpecialityLabel, ColumnAlignment.Center, DataValue.DataType.Long); break; case SaxSport.Column.SpecialityLabel_Desc: SetSportColDfn(columnDfn, "Speciality label", 100, SaxDbDfn_Core.ColumnIdx.Sport_SpecialityLabel, ColumnAlignment.Center); break; //----------------------------------------------------------- // Derived properties. //----------------------------------------------------------- // Common properties. case SaxSport.Column.Notes: SetSportColDfn(columnDfn, "Notes", 240, SaxDbDfn_Core.ColumnIdx.Sport_Notes); break; case SaxSport.Column.Flags: SetSportColDfn(columnDfn, "Flags", 60, SaxDbDfn_Core.ColumnIdx.Sport_Flags, ColumnAlignment.Center, DataValue.DataType.Long); break; case SaxSport.Column.Status: SetSportColDfn(columnDfn, "Status", 80, SaxDbDfn_Core.ColumnIdx.Sport_Status, ColumnAlignment.Center); break; case SaxSport.Column.Status_Desc: SetSportColDfn(columnDfn, "Status", 90, SaxDbDfn_Core.ColumnIdx.Sport_Status, ColumnAlignment.Center); break; case SaxSport.Column.Status_Ind: SetSportColDfn(columnDfn, "Status", 80, SaxDbDfn_Core.ColumnIdx.Sport_Status, ColumnAlignment.Center, DataValue.DataType.TriState); columnDfn.TriStateFormat = ColumnTriStateFormat.Lights; break; case SaxSport.Column.CreateOn_Date: SetSportColDfn(columnDfn, "Created", 80, SaxDbDfn_Core.ColumnIdx.Sport_CreateOn, ColumnAlignment.Center, DataValue.DataType.Date); columnDfn.ReadOnly = true; break; case SaxSport.Column.UpdateOn_Date: SetSportColDfn(columnDfn, "Updated", 80, SaxDbDfn_Core.ColumnIdx.Sport_UpdateOn, ColumnAlignment.Center, DataValue.DataType.Date); columnDfn.ReadOnly = true; break; //----------------------------------------------------------- } if (!String.IsNullOrEmpty(caption)) columnDfn.Caption = caption; if (width > 0) columnDfn.Width = width; return columnDfn; } //------------------------------------------------------------------- // Item query filter. public override List GetSportQueryFilter(SaxSport.Params prm) { List filter = new List(); // Item Ids. String includedIds = prm.IdsIncluded.Concat(","); if (!includedIds.IsEmpty()) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Id, aliasSport) + " IN (" + includedIds + ")"); String excludedIds = prm.IdsExcluded.Concat(","); if (!excludedIds.IsEmpty()) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Id, aliasSport) + " NOT IN (" + excludedIds + ")"); // Generic filter. if (!StringUtil.IsEmpty(prm.SportFilter)) { // Split filter into words. List filterWords = prm.SportFilter.Split((char[])null).ToList(); filterWords.RemoveDuplicatesCI(); filterWords.RemoveBlanks(); foreach (String filterWord in filterWords) { List sportFilter = new List(); sportFilter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Name, aliasSport) + " Like '%" + DbQuery.FormatForLike(filterWord, true) + "%'"); filter.Add(sportFilter.Concat(" OR ", "(", ")")); } } // Name. if (!StringUtil.IsEmpty(prm.NameFull)) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Name, aliasSport) + "='" + DbQuery.FormatForCondition(prm.NameFull) + "'"); if (!StringUtil.IsEmpty(prm.NamePartial)) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Name, aliasSport) + " Like '%" + DbQuery.FormatForLike(prm.NamePartial, true) + "%'"); // Notes. if (!StringUtil.IsEmpty(prm.NotesPartial)) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Notes, aliasSport) + " LIKE '%" + DbQuery.FormatForLike(prm.NotesPartial) + "%'"); // Status. if (prm.StatusCat != SaxSport.StatusCat.Any) filter.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Status, aliasSport) + GetSportStatusCatFilterCondition(prm.StatusCat)); if (filter.Count < 1) filter.Add("1=1"); return filter; } internal static String GetSportStatusCatFilterCondition(SaxSport.StatusCat statusCat) { if (statusCat == SaxSport.StatusCat.ActiveOnly) return "='" + SacsSystem.GetStatusCode(SaStatus.Active) + "'"; if (statusCat == SaxSport.StatusCat.InactiveOnly) return "='" + SacsSystem.GetStatusCode(SaStatus.Inactive) + "'"; if (statusCat == SaxSport.StatusCat.NotDeleted) return "!='" + SacsSystem.GetStatusCode(SaStatus.Deleted) + "'"; if (statusCat == SaxSport.StatusCat.DeletedOnly) return "='" + SacsSystem.GetStatusCode(SaStatus.Deleted) + "'"; return ""; } // Item sort columns. public List GetSportSortColumns(SaxSport.Params prm) { // Sort sequence: List sortColumnNames = new List(); foreach (var columnDfn in prm.SortColumns) { // Need to ensure correct alias used for Sport columns in case of conflict. String sortCol = String.Empty; if (SaxDbDfn_Core.GetTableForColumn((SaxDbDfn_Core.ColumnIdx)columnDfn.DbColumn) == SaxDbDfn_Core.TableIdx.Sport) { sortCol = SaxDbDfn_Core.GetColumnNameQual((SaxDbDfn_Core.ColumnIdx)columnDfn.DbColumn, aliasSport); } else { sortCol = columnDfn.DataName; if (!StringUtil.IsEmpty(columnDfn.SortDataName)) sortCol = columnDfn.SortDataName; } if (!sortCol.IsEmpty()) { DbOrderByNullMode orderByNullMode = DbOrderByNullMode.Default; // eSaOrderByDemoteNulls, eSaOrderByPromoteNulls sortColumnNames.Add(DbQuery.FormatForOrderBy(sortCol, columnDfn.SortAscending, orderByNullMode).Concat(", ")); } } sortColumnNames.RemoveBlanks(); if (sortColumnNames.IsEmpty()) { // Default sort columns. sortColumnNames.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Id, aliasSport) + " ASC"); } return sortColumnNames; } //------------------------------------------------------------------- // Item count. private long GetSportCount(String filter) { ClearErrorState(); return CoreDatabase.GetRowCount(SaxDbDfn_Core.GetTableName(SaxDbDfn_Core.TableIdx.Sport) + " As " + aliasSport, filter); } public override long GetSportCount(SaxSport.Params prm) { ClearErrorState(); return GetSportCount(GetSportQueryFilter(prm).Concat(" AND ", "(", ")")); } //------------------------------------------------------------------- // Item list. public override List GetSportList(SaxSport.Params prm) { List userReferences = new List(); DbQuery qry = new DbQuery(CoreDatabase.DbmsType); qry.Tables.Add(SaxDbDfn_Core.GetTableName(SaxDbDfn_Core.TableIdx.Sport), aliasSport); Sport_Db dbSport = new Sport_Db(CoreDbInfo); qry.Columns.AddRange(dbSport.ExistingColumnNames); qry.Filters.AddRange(GetSportQueryFilter(prm)); qry.OrderBy.AddRange(GetSportSortColumns(prm)); // Query data. using (var dbConnection = CoreDatabase.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); dbCommand.CommandText = qry.BuildQuery(prm.ResultsPaging); using (DbDataReader dbDataReader = dbCommand.ExecuteReader()) { while (dbDataReader.Read()) { dbSport = new Sport_Db(CoreDbInfo); dbSport.PopulateFrom(dbDataReader); userReferences.Add(CreateSport(dbSport)); } } } catch (Exception exc) { SaLogger.Warn(GetType().Name + ".GetSportList\n\tQuery: " + dbCommand.CommandText + "\n\t" + ExceptionUtil.GetLogMessage(exc)); } } return userReferences; } //------------------------------------------------------------------- // Item query execution. public override DbResultSet ExecuteSportQuery(List columns, SaxSport.Params prm) { ClearErrorState(); //--------------------------------------------------------------------- // Construct query. DbQuery query = new DbQuery(CoreDatabase.DbmsType); query.Tables.Add(SaxDbDfn_Core.GetTableName(SaxDbDfn_Core.TableIdx.Sport), aliasSport); // Add columns as defined in query list. if (columns.HasId(SaxSport.Column.Id)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Id, aliasSport)); if (columns.HasId(SaxSport.Column.Name)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Name, aliasSport)); if (columns.HasId(SaxSport.Column.SpecialityLabel) || columns.HasId(SaxSport.Column.SpecialityLabel_Desc)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_SpecialityLabel, aliasSport)); // Common properties. if (columns.HasId(SaxSport.Column.Notes)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Notes, aliasSport)); if (columns.HasId(SaxSport.Column.Flags)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Flags, aliasSport)); if (columns.HasId(SaxSport.Column.Status) || columns.HasId(SaxSport.Column.Status_Desc) || columns.HasId(SaxSport.Column.Status_Ind)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_Status, aliasSport)); if (columns.HasId(SaxSport.Column.CreateOn_Date)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_CreateOn, aliasSport)); if (columns.HasId(SaxSport.Column.UpdateOn_Date)) query.Columns.Add(SaxDbDfn_Core.GetColumnNameQual(SaxDbDfn_Core.ColumnIdx.Sport_UpdateOn, aliasSport)); //--------------------------------------------------------------------- // Movement count. /* if (columns.HasId(SaxSport.Column.Movement_Count)) { // Ref. SaxSport_Dbas.HasAssetMovements String aliasMovement = "aCntMov"; DbQuery queryMovement = new DbQuery(SaxDatabase.DbmsType); queryMovement.Tables.Add(SaxDbDfn.GetTableName(SaxDbDfn.TableIdx.AssetMovement), aliasMovement); queryMovement.Columns.Add("Count(*)"); queryMovement.Filters.Add(SaxDbDfn.GetColumnNameQual(SaxDbDfn.ColumnIdx.AssetMovement_AssetItemType, aliasMovement) + "=" + (int)Sax.AssetItemType.Sport); queryMovement.Filters.Add(SaxDbDfn.GetColumnNameQual(SaxDbDfn.ColumnIdx.AssetMovement_AssetItemId, aliasMovement) + "=" + SaxDbDfn.GetColumnNameQual(SaxDbDfn.ColumnIdx.Sport_Id, aliasSport)); query.Columns.Add("(" + queryMovement.BuildQuery() + ")", colSport_Movement_Count); } */ //--------------------------------------------------------------------- // Populate filter. query.Filters.AddRange(GetSportQueryFilter(prm)); if (prm.IdsIncluded.Count != 1) { // Configure sort sequence. foreach (String sortColumn in GetSportSortColumns(prm)) query.OrderBy.Add(sortColumn); } //--------------------------------------------------------------------- //return new DbResultSet_DataTableReader(db, query.BuildQuery(prm.ResultsPaging)); return DbResultSet_DataReader.ExecuteQuery(CoreDatabase, query.BuildQuery(prm.ResultsPaging)); } //------------------------------------------------------------------- } //======================================================================= }