Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ba0646f27c | ||
|
|
76922a4039 | ||
|
|
e3869b26c3 | ||
|
|
be7277fada | ||
|
|
b8218fbacd | ||
|
|
253f63dfac | ||
|
|
d6337ef591 | ||
|
|
1253a935b7 | ||
|
|
2d4a4d5f7e |
@@ -9,7 +9,7 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System.Attributes
|
||||
[AttributeUsage(AttributeTargets.Field, Inherited = false, AllowMultiple = false)]
|
||||
public class DbForeignObject : Attribute
|
||||
{
|
||||
public Type _foreignObjectType;
|
||||
public Type foreignObjectType;
|
||||
|
||||
public string _foreignKeyName;
|
||||
public DbForeignKey foreignKeyAttribute;
|
||||
@@ -20,11 +20,9 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System.Attributes
|
||||
/// <summary>
|
||||
/// Marks variable as foreign-object of an dbObject
|
||||
/// </summary>
|
||||
/// <param name="foreignObjectType">Type of foreignObject</param>
|
||||
/// <param name="foreignKeyName">Fieldname of foreignKey associated with the foreignObject</param>
|
||||
public DbForeignObject(Type foreignObjectType, string foreignKeyName = null)
|
||||
public DbForeignObject(string foreignKeyName = null)
|
||||
{
|
||||
this._foreignObjectType = foreignObjectType;
|
||||
this._foreignKeyName = foreignKeyName;
|
||||
}
|
||||
|
||||
@@ -32,9 +30,10 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System.Attributes
|
||||
{
|
||||
this.parentField = fi;
|
||||
this.classAttribute = classAttribute;
|
||||
this.foreignObjectType = fi.GetType();
|
||||
|
||||
// Init foreign-object class
|
||||
DbObject foreignClassAttribute = ClassAction.Init(this._foreignObjectType);
|
||||
DbObject foreignClassAttribute = ClassAction.Init(this.foreignObjectType);
|
||||
|
||||
// Check if something is weird
|
||||
if (foreignClassAttribute.primaryKeyAttributes.Count < 1) throw new InvalidOperationException($"'{foreignClassAttribute.parentClassType.Name}' does not have a primaryKey.");
|
||||
|
||||
@@ -71,7 +71,7 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System.Attributes
|
||||
}
|
||||
catch(InvalidOperationException ex)
|
||||
{
|
||||
throw new InvalidOperationException($"Cannot init foreignObject-field '{fi.Name}' of '{classType.Name}'. {ex.Message}", ex);
|
||||
throw new InvalidOperationException($"Cannot init foreignObject-field '{fi.Name}' of '{classType.Name}'. {ex.Message}");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,7 +8,7 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
|
||||
{
|
||||
public class ClassAction
|
||||
{
|
||||
private static List<Type> initiatedClassTypes = new List<Type>() { };
|
||||
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/>
|
||||
@@ -18,16 +18,21 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
|
||||
/// <returns>DbObject-attribute corresponding to the class</returns>
|
||||
public static DbObject Init(Type classType)
|
||||
{
|
||||
// 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'");
|
||||
DbObject cachedDbObject;
|
||||
initiatedClassTypes.TryGetValue(classType, out cachedDbObject);
|
||||
|
||||
if (!initiatedClassTypes.Contains(classType))
|
||||
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'");
|
||||
|
||||
dbObject.Init(classType); // Init dbObject
|
||||
initiatedClassTypes.Add(classType); // Set it to the list
|
||||
initiatedClassTypes.Add(classType, dbObject); // Set it to the list
|
||||
|
||||
cachedDbObject = dbObject;
|
||||
}
|
||||
|
||||
return dbObject;
|
||||
return cachedDbObject;
|
||||
}
|
||||
|
||||
|
||||
@@ -69,7 +74,6 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
|
||||
/// <typeparam name="T"></typeparam>
|
||||
/// <param name="classObject">Given object (marked with Db-attributes)</param>
|
||||
/// <param name="queryExecutor">Function to handle query-calls - Has to return Dictionary[attributeName, attributeValue]</param>
|
||||
/// <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, object primaryKeyValue, Func<string, List<Dictionary<string, object>>> queryExecutor) where T : new()
|
||||
{
|
||||
Dictionary<string, object> primaryKeyData = new Dictionary<string, object>() { };
|
||||
@@ -115,13 +119,25 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
|
||||
if (!dataMatchFound) throw new InvalidOperationException($"Cannot create object with primaryKeyData. No data assigned to field '{primaryKeyAtt.parentField.Name}'");
|
||||
}
|
||||
|
||||
string query = QueryBuilder.SelectByPrimaryKey(obj); // Generate query
|
||||
List<Dictionary<string, object>> dataSet = queryExecutor(query); // Execute
|
||||
FillObject(obj, dataSet[0]); // Fill the object
|
||||
ResolveByPrimaryKey<T>(obj, queryExecutor);
|
||||
|
||||
return obj;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Resolves dbObject by primaryKey/s<pragma/>
|
||||
/// Object needs to have primaryKey/s set!
|
||||
/// </summary>
|
||||
/// <typeparam name="T"></typeparam>
|
||||
/// <param name="classObject">Given object (marked with Db-attributes)</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)
|
||||
{
|
||||
string query = QueryBuilder.SelectByPrimaryKey(classObject); // Generate query
|
||||
List<Dictionary<string, object>> dataSet = queryExecutor(query); // Execute
|
||||
FillObject(classObject, dataSet[0]); // Fill the object
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Gets a list of dbObjects by attribute/s
|
||||
/// </summary>
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
<TargetFramework>netcoreapp2.1</TargetFramework>
|
||||
<RootNamespace>eu.railduction.netcore.dll.Database_Attribute_System</RootNamespace>
|
||||
<SignAssembly>false</SignAssembly>
|
||||
<Version>1.5</Version>
|
||||
<Version>1.5.7</Version>
|
||||
</PropertyGroup>
|
||||
|
||||
</Project>
|
||||
|
||||
@@ -138,7 +138,67 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
|
||||
return BuildQuery(param);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Builds an INSERT-Sql-query based on an object<para/>
|
||||
/// </summary>
|
||||
/// <param name="tableName"></param>
|
||||
/// <param name="dbAttributes"></param>
|
||||
/// <returns></returns>
|
||||
public static string InsertAttributesByObject<T>(T classObject)
|
||||
{
|
||||
Type classType = classObject.GetType();
|
||||
|
||||
// Read dbObject-attribute
|
||||
DbObject dbObject = ClassAction.Init(classType);
|
||||
|
||||
List<string> attributes = new List<string>() { };
|
||||
List<object> data = new List<object>() { };
|
||||
foreach(BaseAttribute baseAttribute in dbObject.baseAttributes)
|
||||
{
|
||||
attributes.Add(baseAttribute._attributeName);
|
||||
data.Add(baseAttribute.parentField.GetValue(classObject));
|
||||
}
|
||||
|
||||
return InsertAttributes(dbObject._tableName, attributes, data);
|
||||
}
|
||||
public static string InsertAttributes(string tableName, Dictionary<string, object> dbAttributes)
|
||||
{
|
||||
if (dbAttributes.Count == 0) throw new InvalidOperationException("Cannot generate SQL-Query. No attributes to insert.");
|
||||
|
||||
List<string> attributes = new List<string>() { };
|
||||
List<object> data = new List<object>() { };
|
||||
|
||||
foreach (KeyValuePair<string, object> attribute in dbAttributes)
|
||||
{
|
||||
attributes.Add(attribute.Key);
|
||||
data.Add(attribute.Value);
|
||||
}
|
||||
|
||||
return InsertAttributes(tableName, attributes, data);
|
||||
}
|
||||
public static string InsertAttributes(string tableName, List<string> attributes, List<object> data)
|
||||
{
|
||||
if (attributes.Count != data.Count) throw new InvalidOperationException("Cannot generate SQL-Query. Attribute-count and data-count not equal.");
|
||||
|
||||
string attributesSeperatedByComma = "";
|
||||
object[] attributeData = new object[attributes.Count*2];
|
||||
int c = 0;
|
||||
for(int i=0; i<attributes.Count*2; i+=2)
|
||||
{
|
||||
attributesSeperatedByComma += attributes[i];
|
||||
attributeData[c] = data[i+1];
|
||||
|
||||
if(c+1 != attributes.Count*2)
|
||||
{
|
||||
attributesSeperatedByComma += ", ";
|
||||
attributeData[c+1] = ",";
|
||||
}
|
||||
c +=2;
|
||||
}
|
||||
|
||||
// Build and return the query
|
||||
return BuildQuery($"INSERT INTO {tableName} ({attributesSeperatedByComma}) VALUES (", attributeData, ")");
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user