5 Commits

Author SHA1 Message Date
Alexander B
be7277fada Set version 1.5.6 2019-04-12 13:36:02 +02:00
Alexander B
b8218fbacd Added InsertAttributesByObject 2019-04-12 13:35:18 +02:00
Alexander B
253f63dfac Added InsertAttributes to generate insert-statements 2019-04-12 12:54:37 +02:00
Alexander B
d6337ef591 Ser version 2019-04-12 11:39:25 +02:00
Alexander B
1253a935b7 Added ResolveByPrimaryKey to resolve an object with set primaryKey/s 2019-04-12 11:33:30 +02:00
3 changed files with 77 additions and 6 deletions

View File

@@ -69,7 +69,6 @@ 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="queryExecutor">Function to handle query-calls - Has to return Dictionary[attributeName, attributeValue]</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() 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>() { }; Dictionary<string, object> primaryKeyData = new Dictionary<string, object>() { };
@@ -115,13 +114,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}'"); 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 ResolveByPrimaryKey<T>(obj, queryExecutor);
List<Dictionary<string, object>> dataSet = queryExecutor(query); // Execute
FillObject(obj, dataSet[0]); // Fill the object
return obj; 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> /// <summary>
/// Gets a list of dbObjects by attribute/s /// Gets a list of dbObjects by attribute/s
/// </summary> /// </summary>

View File

@@ -4,7 +4,7 @@
<TargetFramework>netcoreapp2.1</TargetFramework> <TargetFramework>netcoreapp2.1</TargetFramework>
<RootNamespace>eu.railduction.netcore.dll.Database_Attribute_System</RootNamespace> <RootNamespace>eu.railduction.netcore.dll.Database_Attribute_System</RootNamespace>
<SignAssembly>false</SignAssembly> <SignAssembly>false</SignAssembly>
<Version>1.5.1</Version> <Version>1.5.6</Version>
</PropertyGroup> </PropertyGroup>
</Project> </Project>

View File

@@ -138,7 +138,67 @@ namespace eu.railduction.netcore.dll.Database_Attribute_System
return BuildQuery(param); 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, ")");
}