@ -1,6 +1,5 @@
using eu.railduction.netcore.dll.Database_Attribute_System.Attributes ; using eu.railduction.netcore.dll.Database_Attribute_System.Attributes ;
using System ; using System ;
using System.Collections ;
using System.Collections.Generic ; using System.Collections.Generic ;
using System.Reflection ; using System.Reflection ;
using System.Text ; using System.Text ;
@ -9,33 +8,6 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
{ {
public class ClassAction
public class ClassAction
{
{
private static Dictionary < Type , DbObject > initiatedClassTypes = new Dictionary < Type , DbObject > ( ) { } ;
/// <summary>
/// Initiates the attribute-system and preloads all necessary information<para/>
/// INFO: Will initiate necessary foreignObjects recursively!<para/>
/// If an class is already initiated, it will be ignored!
/// </summary>
/// <param name="classType">The classType to preload</param>
/// <returns>DbObject-attribute corresponding to the class</returns>
public static DbObject Init ( Type classType )
{
DbObject cachedDbObject ;
initiatedClassTypes . TryGetValue ( classType , out cachedDbObject ) ;
if ( cachedDbObject = = null )
{
// Check if given class is marked as dbObject
if ( ! ( classType . GetCustomAttribute ( typeof ( DbObject ) , true ) is DbObject dbObject ) ) throw new InvalidOperationException ( $"Cannot init '{classType.Name}'. Missing Attribute 'DbObject'" ) ;
initiatedClassTypes . Add ( classType , dbObject ) ; // Set it to the list
dbObject . Init ( classType ) ; // Init dbObject
cachedDbObject = dbObject ;
}
return cachedDbObject ;
}
/// <summary>
/// <summary>
/// Fills an given dbObject with given data<para/>
/// Fills an given dbObject with given data<para/>
/// Data-attribute-names and class-fieldNames have to match! (non case-sensitive)
/// Data-attribute-names and class-fieldNames have to match! (non case-sensitive)
@ -43,177 +15,79 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
/// <typeparam name="T"></typeparam>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="data">The data</param>
/// <param name="data">The data</param>
/// <param name="key">Key-name of data</param>
/// <param name="runDataLossChecks">This checks if any class-field and data-attribute does not exists in either (Slower)</param>
public static void FillObject < T > ( T classObject , string key , object data )
public static void FillObject < T > ( T classObject , Dictionary < string , object > data , bool runDataLossChecks = true )
{
Dictionary < string , object > dicData = new Dictionary < string , object > ( ) ;
dicData . Add ( key , data ) ;
FillObject < T > ( classObject , dicData ) ;
}
/// <summary>
/// Fills an given dbObject with given data<para/>
/// Data-attribute-names and class-fieldNames have to match! (non case-sensitive)
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="data">The data</param>
/// <param name="key">Key-name of data</param>
public static void FillObject < T > ( T classObject , Dictionary < string , object > data )
{
{
Type classType = classObject . GetType ( ) ;
Type classType = classObject . GetType ( ) ;
// Read dbObject-attribute
string tableName = Function . GetDbTableName ( classType ) ;
DbObject dbObject = ClassAction . Init ( classType ) ;
// Iterate through data
// Get class-fields
foreach ( KeyValuePair < string , object > data_keySet in data )
Dictionary < string , FieldInfo > dbFields = Function . ReadDbClassFields ( classType ) ;
{
bool dataMatchFound = false ;
// Interate through class-fields
if ( runDataLossChecks )
foreach ( BaseAttribute baseAttribute in dbObject . baseAttributes )
{
{
// Remove any leading dots and table-specifiers
// Check every data-attribute for match in class-fields
string dbAttName = data_keySet . Key ;
foreach ( KeyValuePair < string , object > data_keySet in data )
if ( dbAttName . Contains ( "." ) )
{
string [ ] dbAttNameSplit = dbAttName . Split ( '.' ) ; // Split at the '.'
dbAttName = dbAttNameSplit [ dbAttNameSplit . Length - 1 ] ; // Copy the ending text
}
// If its a match, set the value
if ( baseAttribute . _attributeName . ToLower ( ) = = data_keySet . Key . ToLower ( ) )
{
{
object value = data_keySet . Valu e;
bool isFound = false ;
if ( ! ( value is DBNull ) ) // Check if value is empty
foreach ( KeyValuePair < string , FieldInfo > field_keySet in dbFields )
{
{
baseAttribute . parentField . SetValue ( classObject , value ) ;
if ( field_keySet . Key . ToLower ( ) = = data_keySet . Key . ToLower ( ) )
isFound = true ;
}
}
dataMatchFound = true ;
if ( ! isFound )
break ;
throw new InvalidOperationException ( $"Could not fill object. Data-Attribute '{data_keySet.Key}' was not found in class!" ) ;
}
}
if ( ! dataMatchFound ) throw new InvalidOperationException ( $"Attribute '{data_keySet.Key}' has no match in object '{classObject.GetType().Name}'" ) ;
}
}
}
// Check every class-field for match in data-attributes
foreach ( KeyValuePair < string , FieldInfo > field_keySet in dbFields )
/// <summary>
/// Gets an dbObject by primaryKey/s
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classType">The classType (marked with Db-attributes)</param>
/// <param name="primaryKeyName">Name of the primaryKey</param>
/// <param name="primaryKeyValue">Value of the primaryKey</param>
/// <param name="primaryKeyData">KeyData of multiple primaryKeys</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
public static T GetByPrimaryKey < T > ( Type classType , object primaryKeyValue , Func < string , List < Dictionary < string , object > > > queryExecutor ) where T : new ( )
{
{
// Read dbObject-attribute
bool isFound = false ;
DbObject dbObject = ClassAction . Init ( classType ) ;
foreach ( KeyValuePair < string , object > data_keySet in data )
if ( dbObject . primaryKeyAttributes . Count < 1 ) throw new InvalidOperationException ( $"No primaryKey found in '{classType.Name}'" ) ;
if ( dbObject . primaryKeyAttributes . Count > 1 ) throw new InvalidOperationException ( $"This 'GetByPrimaryKey' method only supports 1 primaryKey ('{dbObject.primaryKeyAttributes.Count}' found in '{classType.Name}')" ) ;
return GetByPrimaryKey < T > ( classType , dbObject . primaryKeyAttributes [ 0 ] . _attributeName , primaryKeyValue , queryExecutor ) ;
}
/// <summary>
/// Gets an dbObject by primaryKey/s
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classType">The classType (marked with Db-attributes)</param>
/// <param name="primaryKeyName">Name of the primaryKey</param>
/// <param name="primaryKeyValue">Value of the primaryKey</param>
/// <param name="primaryKeyData">KeyData of multiple primaryKeys</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
public static T GetByPrimaryKey < T > ( Type classType , string primaryKeyName , object primaryKeyValue , Func < string , List < Dictionary < string , object > > > queryExecutor ) where T : new ( )
{
{
Dictionary < string , object > primaryKeyData = new Dictionary < string , object > ( ) { } ;
if ( field_keySet . Key . ToLower ( ) = = data_keySet . Key . ToLower ( ) )
primaryKeyData . Add ( primaryKeyName , primaryKeyValue ) ;
isFound = true ;
return GetByPrimaryKey < T > ( classType , primaryKeyData , queryExecutor ) ;
}
}
/// <summary>
/// Gets an dbObject by primaryKey/s
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classType">The classType (marked with Db-attributes)</param>
/// <param name="primaryKeyName">Name of the primaryKey</param>
/// <param name="primaryKeyValue">Value of the primaryKey</param>
/// <param name="primaryKeyData">KeyData of multiple primaryKeys</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
public static T GetByPrimaryKey < T > ( Type classType , Dictionary < string , object > primaryKeyData , Func < string , List < Dictionary < string , object > > > queryExecutor ) where T : new ( )
{
// Read dbObject-attribute
DbObject dbObject = ClassAction . Init ( classType ) ;
if ( dbObject . primaryKeyAttributes . Count < 1 ) throw new InvalidOperationException ( $"No primaryKey found in '{classType.Name}'" ) ;
if ( ! isFound )
throw new InvalidOperationException ( $"Could not fill object. Class-field '{field_keySet.Key}' was not found in data!" ) ;
// Create new empty object
}
T obj = ( T ) dbObject . parentCInfo . Invoke ( null ) ;
}
// iterate thru them to check and fill object
// Iterate through data
foreach ( DbPrimaryKey primaryKeyAtt in dbObject . primaryKeyAttributes )
foreach ( KeyValuePair < string , object > data_keySet in data )
{
{
bool dataMatchFound = false ;
// Interate through class-fields
foreach ( KeyValuePair < string , FieldInfo > field_keySet in dbFields )
// Now search the corresponding primaryKeyData
foreach ( KeyValuePair < string , object > primaryKey in primaryKeyData )
{
{
// primaryKey matches
// If its a match, set the value
if ( primaryKeyAtt . _attributeName . ToLower ( ) = = primaryKey . Key . ToLower ( ) )
if ( field_keySet . Key . ToLower ( ) = = data_keySet . Key . ToLower ( ) )
{
{
// Set data
field_keySet . Value . SetValue ( classObject , data_keySet . Value ) ;
primaryKeyAtt . parentField . SetValue ( obj , primaryKey . Value ) ;
dataMatchFound = true ;
break ;
break ;
}
}
}
}
// If no data was found matching this field
if ( ! dataMatchFound ) throw new InvalidOperationException ( $"PrimaryKey='{primaryKeyAtt.parentField.Name}' is missing." ) ;
}
}
try
{
ResolveByPrimaryKey < T > ( obj , queryExecutor ) ;
} catch ( InvalidOperationException )
{
// If there is no result, return null
return default ( T ) ;
}
}
return obj ;
}
// ----
/// <summary>
/// <summary>
/// Gets a ll dbObjects of class/table
/// Gets an dbObject
/// </summary>
/// </summary>
/// <typeparam name="T"></typeparam>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="queryExecutor">Function to handle query-calls - Has to return Dictionary[attributeName, attributeValue]</param>
public static List < T > GetList < T > ( Type classType , Func < string , List < Dictionary < string , object > > > queryExecutor ) where T : new ( )
/// <param name="runDataLossChecks">This checks if any class-field and data-attribute does not exists in either (Slower)</param>
public static T GetByPrimaryKey < T > ( Type classType , Func < string , List < Dictionary < string , object > > > queryExecutor , bool runDataLossChecks = true ) where T : new ( )
{
{
// Read dbObject - attribute
T obj = new T ( ) ;
DbObject dbObject = ClassAction . Init ( classType ) ;
string query = QueryBuilder . SelectBy Attribute( dbObject . _tableName ) ; // Generate query
string query = QueryBuilder . SelectBy PrimaryKey( obj ) ; // Generate query
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
FillObject ( obj , dataSet [ 0 ] , runDataLossChecks ) ; // Fill the object
List < T > objs = new List < T > ( ) { } ;
return obj ;
foreach ( Dictionary < string , object > data in dataSet )
{
T obj = new T ( ) ; // New object
FillObject ( obj , data ) ; // Fill it
objs . Add ( obj ) ; // Add to list
}
return objs ; // Return list
}
}
/// <summary>
/// <summary>
@ -222,366 +96,67 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
/// <typeparam name="T"></typeparam>
/// <typeparam name="T"></typeparam>
/// <param name="classType">Type of class</param>
/// <param name="classType">Type of class</param>
/// <param name="fields">class-fields for select</param>
/// <param name="fields">class-fields for select</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="queryExecutor">Function to handle query-calls - Has to return Dictionary[attributeName, attributeValue]</param>
/// <returns>List of dbObjects</returns>
/// <param name="runDataLossChecks">This checks if any class-field and data-attribute does not exists in either (Slower)</param>
public static List < T > GetListByAttribute < T > ( Type classType , Dictionary < string , object > fields , Func < string , List < Dictionary < string , object > > > queryExecutor ) where T : new ( )
/// <returns></returns>
public static List < T > GetListByAttribute < T > ( Type classType , Dictionary < string , object > fields , Func < string , List < Dictionary < string , object > > > queryExecutor , bool runDataLossChecks = true ) where T : new ( )
{
{
// Read dbObject-attribute
string tableName = Function . GetDbTableName ( classType ) ; // Get database-tableName
DbObject dbObject = ClassAction . Init ( classType ) ;
Function . ConvertAttributeToDbAttributes ( classType , fields ) ;
Function . ConvertAttributeToDbAttributes ( classType , fields ) ;
string query = QueryBuilder . SelectByAttribute ( dbObject. _ tableName, fields ) ; // Generate query
string query = QueryBuilder . SelectByAttribute ( , fields ) ; // Generate query
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
List < T > objs = new List < T > ( ) { } ;
List < T > objs = new List < T > ( ) { } ;
foreach ( Dictionary < string , object > data in dataSet )
foreach ( Dictionary < string , object > data in dataSet )
{
{
T obj = new T ( ) ; // New object
T obj = new T ( ) ; // New object
FillObject ( obj , data ; // Fill it
FillObject ( obj , data , runDataLossChecks ); // Fill it
objs . Add ( obj ) ; // Add to list
objs . Add ( obj ) ; // Add to list
}
}
return objs ; // Return list
return objs ; // Return list
}
}
/// <summary>
/// Gets an dbObject by custom where-clause
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="whereClause">Custom where-clause params attached to query (SELECT * FROM tableName WHERE whereClause)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
public static List < T > GetListWithWhere < T > ( Type classType , Func < string , List < Dictionary < string , object > > > queryExecutor , params object [ ] whereClause ) where T : new ( )
{
// Read dbObject - attribute
DbObject dbObject = ClassAction . Init ( classType ) ;
string query = QueryBuilder . SelectWithWhere ( dbObject . _tableName , whereClause ) ; // Generate query
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
List < T > objs = new List < T > ( ) { } ;
foreach ( Dictionary < string , object > data in dataSet )
{
T obj = new T ( ) ; // New object
FillObject ( obj , data ) ; // Fill it
objs . Add ( obj ) ; // Add to list
}
return objs ; // Return list
}
/// <summary>
/// Gets an dbObject by full query
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="customQuery">Custom sql-query</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
public static List < T > GetListWithQuery < T > ( Type classType , Func < string , List < Dictionary < string , object > > > queryExecutor , params object [ ] customQuery ) where T : new ( )
{
// Read dbObject - attribute
DbObject dbObject = ClassAction . Init ( classType ) ;
string query = QueryBuilder . BuildQuery ( customQuery ) ;
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
List < T > objs = new List < T > ( ) { } ;
foreach ( Dictionary < string , object > data in dataSet )
{
T obj = new T ( ) ; // New object
FillObject ( obj , data ) ; // Fill it
objs . Add ( obj ) ; // Add to list
}
return objs ; // Return list
}
// -----
/// <summary>
/// <summary>
/// Resolves dbObject by primaryKey/s<pragma/>
/// Resolves all foreignKeys with the database
/// Object needs to have primaryKey/s set!
/// </summary>
/// </summary>
/// <typeparam name="T"></typeparam>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="queryExecutor">Function to handle query-calls - Has to return Dictionary[attributeName, attributeValue]</param>
public static void ResolveByPrimaryKey < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , bool throwExceptions = true )
{
string query = QueryBuilder . SelectByPrimaryKey ( classObject ) ; // Generate query
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
if ( dataSet . Count = = 0 )
{
if ( throwExceptions ) throw new InvalidOperationException ( $"Cannot fetch '{typeof(T).Name}' by primary key/s. No results!" ) ;
}
else FillObject ( classObject , dataSet [ 0 ] ) ; // Fill the object
}
/// <summary>
/// Resolves all foreignKeys with the database<pragma/>
/// Only works if the foreignKey is single (not assembled)!
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="max_depth">Determents how deep resolving will be executed</param>
/// <param name="max_depth">Determents how deep resolving will be executed</param>
public static void ResolveForeignKeys < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , int max_depth = 1 ) where T : new ( )
/// <param name="runDataLossChecks">This checks if any class-field and data-attribute does not exists in either (Slower)</param>
public static void ResolveForeignKeys < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , int max_depth = 1 , bool runDataLossChecks = true ) where T : new ( )
{
{
Type classType = classObject . GetType ( ) ;
Type classType = classObject . GetType ( ) ;
// Read dbObject-attribute
// Get class-fields
DbObject dbObject = ClassAction . Init ( classType ) ;
Dictionary < string , FieldInfo > dbFields = Function . ReadDbClassFields ( classType ) ;
// Resolve foreignObjects
foreach ( DbForeignObject foreignObjectAtt in dbObject . foreignObjectAttributes )
{
object foreignKey_value = foreignObjectAtt . foreignKeyAttribute . parentField . GetValue ( classObject ) ;
object foreignObject_value = foreignObjectAtt . parentField . GetValue ( classObject ) ;
// When key is set and object is empty, get it & set it
if ( foreignKey_value ! = null & & foreignObject_value = = null )
{
// Resolve it
foreignObject_value = GetByPrimaryKey < T > ( foreignObjectAtt . foreignObjectType , foreignKey_value , queryExecutor ) ;
foreignObjectAtt . parentField . SetValue ( classObject , foreignObject_value ) ; // Set the value
// Now scan the just resolved class to be able to set myself
DbObject foreignDbObject = Init ( foreignObject_value . GetType ( ) ) ;
foreach ( DbReverseForeignObject dbReverseForeignObject in foreignDbObject . reverseForeignObjectAttributes )
{
// If the field-names match
if ( dbReverseForeignObject . _foreignKeyName . ToLower ( ) = = dbObject . primaryKeyAttributes [ 0 ] . _attributeName . ToLower ( ) )
{
object myReference ;
if ( dbReverseForeignObject . parentField . FieldType is IList & & dbReverseForeignObject . parentField . FieldType . IsGenericType ) // 1:m
{
// If its a list, i create a list with just myself
myReference = new List < T > ( ) { classObject } ;
}
else // 1:1
{
// Otherwise ist just myself
myReference = classObject ;
}
dbReverseForeignObject . parentField . SetValue ( foreignObject_value , myReference ) ;
break ;
}
}
}
// Recursive resolving
if ( max_depth > 1 )
{
// Go recursively into the next class
ResolveForeignKeys ( foreignObject_value , queryExecutor , max_depth - 1 ) ;
}
}
// Resolve intermediateForeignObjects
foreach ( DbIntermediateForeignObject intermediateForeignObjectAtt in dbObject . intermediateObjectAttributes )
{
object intermediateForeignObject_value = intermediateForeignObjectAtt . parentField . GetValue ( classObject ) ;
// When its empty, get it & set it
if ( intermediateForeignObject_value = = null )
{
// Generate & set attribute-set
Dictionary < string , object > attributes = new Dictionary < string , object > ( ) ;
attributes . Add ( intermediateForeignObjectAtt . _keyName , dbObject . primaryKeyAttributes [ 0 ] . parentField . GetValue ( classObject ) ) ;
string query = QueryBuilder . SelectByAttribute ( intermediateForeignObjectAtt . _intermediateTableName , attributes ) ; // Generate query
List < Dictionary < string , object > > dataSet = queryExecutor ( query ) ; // Execute
// Extract data
List < object > values = new List < object > ( ) ;
for ( int i = 0 ; i < dataSet . Count ; i + + )
{
Dictionary < string , object > data = dataSet [ i ] ;
object primaryKeyValue = data [ intermediateForeignObjectAtt . foreignPrimaryKeyAttribute . _attributeName ] ;
values . Add ( GetByPrimaryKey < object > ( intermediateForeignObjectAtt . foreignPrimaryKeyAttribute . classAttribute . parentClassType , primaryKeyValue , queryExecutor ) ) ;
}
// Now scan the just resolved class to be able to set myself
DbObject foreignDbObject = Init ( intermediateForeignObjectAtt . foreignPrimaryKeyAttribute . classAttribute . parentClassType ) ;
foreach ( DbForeignObject dbForeignObject in foreignDbObject . foreignObjectAttributes )
{
// If the field-names match
if ( dbForeignObject . _foreignKeyName . ToLower ( ) = = dbObject . primaryKeyAttributes [ 0 ] . _attributeName . ToLower ( ) )
{
object myReference = classObject ;
foreach ( object value in values )
{
dbForeignObject . parentField . SetValue ( value , myReference ) ;
}
break ;
}
}
// Set value
intermediateForeignObject_value = values ;
intermediateForeignObjectAtt . parentField . SetValue ( classObject , intermediateForeignObject_value ) ;
}
// Recursive resolving
if ( max_depth > 1 )
{
// If we have a list of objects, we need to recursively go into each one
foreach ( object value in ( IList ) intermediateForeignObject_value )
{
ResolveForeignKeys ( value , queryExecutor , max_depth - 1 ) ;
}
}
}
// Resolve reverseForeignObjects
foreach ( DbReverseForeignObject reverseForeignObjectAtt in dbObject . reverseForeignObjectAttributes )
{
object reverseForeignObject_value = reverseForeignObjectAtt . parentField . GetValue ( classObject ) ;
Type reverseForeignObject_type = reverseForeignObjectAtt . parentField . GetType ( ) ;
// When its empty, get it & set it
if ( reverseForeignObject_value = = null )
{
// Generate & set attribute-set
Dictionary < string , object > attributes = new Dictionary < string , object > ( ) ;
attributes . Add ( reverseForeignObjectAtt . _foreignKeyName , dbObject . primaryKeyAttributes [ 0 ] . parentField . GetValue ( classObject ) ) ;
List < object > values = GetListByAttribute < object > ( reverseForeignObjectAtt . foreignKeyAttribute . classAttribute . parentClassType , attributes , queryExecutor ) ;
if ( values . Count = = 0 ) throw new InvalidOperationException ( $"'{reverseForeignObjectAtt.parentField.Name}' could not been resolved. ReverseForeignObject returned '{values.Count}' values." ) ;
// Now scan the just resolved class to be able to set myself
foreach ( KeyValuePair < string , FieldInfo > dbField in dbFields )
DbObject foreignDbObject = Init ( reverseForeignObjectAtt . foreignKeyAttribute . classAttribute . parentClassType ) ;
foreach ( DbForeignObject dbForeignObject in foreignDbObject . foreignObjectAttributes )
{
{
// If the field-names match
// If field is foreignKey
if ( dbForeignObject . _foreignKeyName . ToLower ( ) = = dbObject . primaryKeyAttributes [ 0 ] . _attributeName . ToLower ( ) )
if ( dbField . Value . GetCustomAttribute ( typeof ( DbForeignKey ) , true ) is DbForeignKey fkey )
{
{
object myReference = classObject ;
FieldInfo f_Field = fkey . _foreignKeyField ;
foreach ( object value in values )
object f_value = f_Field . GetValue ( classObject ) ;
{
dbForeignObject . parentField . SetValue ( value , myReference ) ;
}
break ;
}
}
// Check for type to determen 1:1 or 1:m
// When its empty, get it
if ( reverseForeignObject_type is IList & & reverseForeignObject_type . IsGenericType ) // List, so 1:m
if ( f_value = = null )
{
{
reverseForeignObject_value = values ;
f_value = GetByPrimaryKey < T > ( classType , queryExecutor , runDataLossChecks ) ; ;
}
else // Not list, so 1:1
{
if ( values . Count > 1 ) throw new InvalidOperationException ( $"'{reverseForeignObjectAtt.parentField.Name}' could not been resolved as ReverseForeignObject returned '{values.Count}' values. (Is it 1:m instead of 1:1?)" ) ;
reverseForeignObject_value = values [ 0 ] ;
}
reverseForeignObjectAtt . parentField . SetValue ( classObject , reverseForeignObject_value ) ;
}
}
// Recursive resolving
// Recursive resolving
if ( max_depth > 1 )
{
if ( reverseForeignObject_value is IList & & reverseForeignObject_type . IsGenericType ) // 1:m
{
// If we have a list of objects, we need to recursively go into each one
foreach ( object value in ( IList ) reverseForeignObject_value )
{
ResolveForeignKeys ( value , queryExecutor , max_depth - 1 ) ;
}
}
else // 1:1
{
// Go recursively into the next class
ResolveForeignKeys ( reverseForeignObject_value , queryExecutor , max_depth - 1 ) ;
}
}
}
}
/// <summary>
/// Updates class to database-object</pragma>
/// Only works with primary-key/s!
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="max_depth">Determents how deep resolving will be executed (if the corresponding foreignKey-object is resolved)</param>
public static void Update < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , int max_depth = 1 )
{
// Read dbObject-attribute
DbObject dbObject = ClassAction . Init ( classObject . GetType ( ) ) ;
if ( max_depth - 1 > 0 )
if ( max_depth - 1 > 0 )
{
{
// Update all foreignObjects before handling myself
ResolveForeignKeys ( f_value , queryExecutor , max_depth - 1 , runDataLossChecks ) ;
foreach ( DbForeignObject foreignObject in dbObject . foreignObjectAttributes )
{
object foreignObjectRef = foreignObject . parentField . GetValue ( classObject ) ;
if ( foreignObjectRef ! = null )
Update ( foreignObjectRef , queryExecutor , max_depth - 1 ) ;
}
}
}
}
string updateQuery = QueryBuilder . UpdateByPrimaryKey ( classObject ) ;
queryExecutor . Invoke ( updateQuery ) ;
}
/// <summary>
/// Inserts class to database-object
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="max_depth">Determents how deep insertion will be executed (if the corresponding foreignKey-object is resolved)</param>
public static void Insert < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , int max_depth = 1 )
{
// Read dbObject-attribute
DbObject dbObject = ClassAction . Init ( classObject . GetType ( ) ) ;
if ( max_depth - 1 > 0 )
{
// Update all foreignObjects before handling myself
foreach ( DbForeignObject foreignObject in dbObject . foreignObjectAttributes )
{
object foreignObjectRef = foreignObject . parentField . GetValue ( classObject ) ;
if ( foreignObjectRef ! = null )
Insert ( foreignObjectRef , queryExecutor , max_depth - 1 ) ;
}
}
string insertQuery = QueryBuilder . InsertAttributesByObject ( classObject ) ;
queryExecutor . Invoke ( insertQuery ) ;
}
/// <summary>
/// Deletes class from database-object</pragma>
/// Only works with primary-key/s!
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="classObject">Given object (marked with Db-attributes)</param>
/// <param name="queryExecutor">Function to handle query-calls</param>
/// <param name="max_depth">Determents how deep deletion will be executed (if the corresponding foreignKey-object is resolved)</param>
public static void Delete < T > ( T classObject , Func < string , List < Dictionary < string , object > > > queryExecutor , int max_depth = 1 )
{
// Read dbObject-attribute
DbObject dbObject = ClassAction . Init ( classObject . GetType ( ) ) ;
if ( max_depth - 1 > 0 )
{
// Update all foreignObjects before handling myself
foreach ( DbForeignObject foreignObject in dbObject . foreignObjectAttributes )
{
object foreignObjectRef = foreignObject . parentField . GetValue ( classObject ) ;
if ( foreignObjectRef ! = null )
Delete ( foreignObjectRef , queryExecutor , max_depth - 1 ) ;
}
}
}
string deleteQuery = QueryBuilder . DeleteByPrimaryKey ( classObject ) ;
queryExecutor . Invoke ( deleteQuery ) ;
}
}
}
}
} }