Skip to content

Lightweight SQL management library for C#

License

Notifications You must be signed in to change notification settings

LowTL/Truffle

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

97 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Truffle Library

Truffle is a lightweight SQL management library written on top of ASP.net that aims to simplify interactions between a backend API and its SQL Databases. Programs written with this library are similar to Java Spring in that they follow a Modelling framework with the use of Attributes to represent tables, columns and fields.

Truffle provides additional flexibility by having all of its classes extendable, and allows the user to implement their own data validations and procedures.

This library was written by POeticPotatoes, who created it in the process of building backend services at work. It is currently in use by the company in question for most of its backend API's, although he no longer works there.

Table of Contents

Introduction

Truffle's classes provide 4 main utilities:

  1. Running queries and procedures in an SQL database with automatic result parsing
  2. Modeling and mapping of table columns to POCOs
  3. Providing data validation for models
  4. Retrieving, updating and inserting values into a table with direct mapping from created models

These functions may be utilised by instantiation and/or extension of Truffle's classes that allow for the flexible retrieval and modification of data.

Installation

A nuget package for this library has yet to be set up, but it may still be added to your dotnet projects manually:

  1. Install the System.Data.SqlClient nuget package
  2. Clone this repository into your project

Technologies

  • Dotnet version: 6.0

Dependencies

  • System.Data.SqlClient Nuget Package provided by ASP.net

Structure Overview

Class Structure

The basic structure of Truffle is shown below:

classDiagram

class DatabaseConnector {
    - connection: SqlConnection
    + RunCommand(text: string): object
}

class DataCollector {
    + ReadValues(reader: SqlReader)$: object[]
    + ReadComplexValues(reader: SqlReader)$: List<Dictionary<string, object>>
}

class SqlObject {
    + GetAllValues(): Dictionary<string, object>
    + BuildAllRequest(): string
    + GetTable(): string
    + GetId(): string
}
<<abstract>> SqlObject

class PartialSqlObject {
    - values: Dictionary<string, object>
    + GetValue(key: string): object
    + GetString(key: string): string
    + GetDate(key: string): DateTime
    + GetBoolean(key: string): bool
}

class GenericSqlObject

class Column {
    + Name: string
}

class Table {
    + Name: string
}

class DataValidatorAttribute {
    + Validate(): bool
}

class DataCleanerAttribute {
    + Clean(): object
}

class Id

class SqlEditor {
    - fields: Dictionary<string, string>
    + Set(column: string, value: object): void
    + SetAll(toAdd: Dictionary<string, object>): void
    - GetFields(): Dictionary<string, string>
}

class SqlInserter {
    Insert(table: string, database: DatabaseConnector): bool
}

class SqlUpdater {
    Update(table: string, database: DatabaseConnector): bool
}

class SqlSelector {
    BuildSelect(table: string, columns: string): string
    BuildObjects(o: SqlObject, database: DatabaseConnector) List<SqlObject>
}

DatabaseConnector *-- SqlConnection
DatabaseConnector ..> DataCollector
SqlObject --> DatabaseConnector
SqlObject *-- Id
SqlObject *-- Column
SqlObject *-- Table
SqlObject *-- DataValidatorAttribute
SqlObject *-- DataCleanerAttribute
SqlObject <|-- PartialSqlObject
PartialSqlObject <|-- GenericSqlObject
SqlEditor <|-- SqlUpdater
SqlEditor <|-- SqlInserter
SqlUpdater *-- SqlSelector
SqlUpdater --> DatabaseConnector
SqlInserter --> DatabaseConnector
SqlSelector --> DatabaseConnector
Loading
  • DatabaseConnector is a wrapper class that holds an SqlConnection. It provides a method to run SQL queries and collect result values with the use of DataCollector
  • DataCollector is a static class that provides methods to collect values from an SQL query into object[] and Dictionary formats
  • SqlObject is an abstract class that represents a model of an entry in a sql table, and classes that extend it may be instantiated with a DatabaseConnector. SqlObject maps values to properties with the use of attributes Column, Table and Id as flags
  • DataValidatorAttribute and DataCleanerAttribute are attributes that can be additionally used by SqlObject to provide data conversions and validations
  • PartialSqlObject is an extension of SqlObject that retrieves column values even if their corresponding properties are not present in the model. This is useful for large tables with many columns.
  • GenericSqlObject is a further extension of PartialSqlObject that removes the need for class extension or definition before it is used. This is useful for tables with unknown names or columns.
  • SqlEditor is an abstract class that provides methods to collect parameters into a Dictionary to perform subsequent SQL queries
  • SqlInserter, SqlUpdater and classes used for table modification that extend the SqlEditor class and respectively provide methods to insert and update data in an SQL table.
  • SqlSelector is a class used to select objects in the database and return values. It may additionally be passed into SqlUpdater to facilitate flexible row selection during updating.

Usage

Table of Contents

Sql Databases and Queries

The connection to an SQL database is created when a DatabaseConnector object is instantiated with a connection string:

public void ConnectToDatabaseExample()
{
    // Get a connection string
    string str = "YourConnectionString";
    using (var database = new DatabaseConnector(str))
    {
        // Use the DatabaseConnector here to run sql queries or to create SqlObjects
    }
}

NOTE: DatabaseConnector is disposable and should hence be used in a disposable context (either with the using keyword or by calling Dispose() when it is no longer needed).

Once it is instantiated, it may then be used to run regular SQL queries or procedures, or create instances of SqlObjects.

Running Commands

Sql queries may be run with the DatabaseConnector by calling its RunCommand() method:

using (var database = new DatabaseConnector(str))
{
    var response = (object[]) database.RunCommand("select * from [dbo].[yourtable]");
}

By default, RunCommand() returns an object[] of all the values from the query, but it may be configured by adding an additional complex argument and setting it to true for it to return a more complex output:

var response = (List<Dictionary<string, object>>) database.RunCommand("mycommand", complex: true);

This is useful when handling a query that would return multiple rows of data, or if you wish to have your values mapped to their respective column names.

Running Procedures

Procedures can be called with the same syntax as a normal Sql query with RunCommand(), but their parameters may also be appended separately with the configuration of additional parameters:

using (var database = new DatabaseConnector(str))
{
    var procedureName = "MyProcedure";
    string[] parameters = ["param1", "param2"]; // Procedure parameters
    var response = (object[]) database.RunCommand(procedureName, true, parameters);

    // Alternatively, call the procedure as a regular SQL query without additional configuration
    var response2 = (object[]) database.RunCommand("MyProcedure 'param1', 'param2'");
}

RunCommand takes true as a second argument to indicate that the command is a procedure instead of a regular query. It then uses the string[] provided as a third argument as parameters to execute the procedure.

Similar to a regular query, complex may also be set to true for a more substantial output.

DatabaseConnector Documentation

namespace Truffle.Database

DatabaseConnector

public class DatabaseConnector: IDisposable

Fields

Modifier and Type Field Summary
private static bool _verbose Determines whether to log commands executed during runtime.
private static ILogger _logger The logger to use when logging information.

Constructors

Modifier Constructor Description
public DatabaseConnector(string connectionstr) Instantiates a connection to an SQL database with a connection string.

Method Summary

Modifier and Type Method Summary
public static void SetVerbose(bool verbose, ILogger logger) Sets whether to log the queries run with DatabaseConnector and provides an ILogger to log with.
public void Dispose() Disposes of a connection to an SQL database. Can be utilised with a using statement.
public object RunCommand(string text, bool isProcedure=false, object[] values=null, bool complex=false) Runs an SQL query and returns the result.
public async Task<object> RunCommandAsync(string text, bool isProcedure=false, object[] values=null, bool complex=false) Runs an SQL query asynchronously and returns the result.

RunCommand()

public object RunCommand(string text, bool isProcedure=false, object[] values=null, bool complex=false)

Runs an SQL query and returns the result.

This returns an object[] by default, but can be configured to return a List<Dictionary<string, object>> by setting the optional parameter of complex to true.

Parameters

  • text - The query to run. Procedures are also accepted queries, but if values is used to pass in parameters for the procedure then only the procedure name is required.
  • isProcedure - Whether the command is a procedure. This only needs to be set to true if values is used to pass in parameters for the procedure.
  • values - An array of objects to pass into the procedure as parameters.
  • complex - Sets the return type of the method to a List<Dictionary<string, object>> if set to true.

RunCommandAsync()

public Task<object> RunCommand(string text, bool isProcedure=false, object[] values=null, bool complex=false)

Similar to RunCommand(), runs an SQL query asynchronously and returns the result.

NOTE: This may require you to enable MultipleActiveResultSets in your SQL connection string.


Creating a Model

In order to make use of the modelling capabilities of Truffle, we must first create a POCO (Plain old C# Object) that represents an entry in our table with some additional annotations:

[Table("[dbo].[tblDog]")]
public class Dog : SqlObject
{
    [Id, Column("Name")]
    public string MyName {get;set;}
    [Column("Age")]
    public int Age {get;set;}
    [Column("Owner")]
    public string Owner {get;set;}
    [Column("dob")]
    public DateTime? DateOfBirth {get;set;}
    [Column("weight")]
    public double Weight {get;set;}
    [Column("happy")]
    public bool IsHappy {get;set;}

    public Dog(): base() {}
}

There are several cases in which you may not know which columns will be returned (For example, in the case of a REST API that might need to return columns but does not need to read them, or if a table has dynamic columns that need to be read). In such cases, the use of a PartialSqlObject might be more suitable.

There are some important things to note:

  1. Dog extends the SqlObject class which provides it with its required additional methods and mappings.
  2. Table is used to indicate the table which stores the data of Dog.
  3. Column is used to indicate the column which the property corresponds to.
  4. Id is used to indicate that the column is a Key (unique). There should only be one Id for every object.

These annotations are based on Java Spring's Database API, so developers who have used the framework will find these familiar.

We can then make use of several of SqlObject's built-in constructors to instantiate our model in different ways:

Instantiating by Key

SqlObject can be instantiated by accepting a value for its Id column:

[Table("[dbo].[tblDog]")]
public class Dog : SqlObject
{
    [Id, Column("Name")]
    public string Name {get;set;}
    // ...
    public Dog(object value, DatabaseConnector db): base(value, db) {}
}

public static class Main
{
    public static void Run()
    {
        using (var database = new DatabaseConnector("MyConnectionString"))
        {
            // Get a dog with Name='Spot'
            var dog = new Dog("Spot", database); 

            // Prints "Hi, my name is Spot!"
            Console.WriteLine($"Hi, my name is {dog.Name}!");
        }
    }
}

Note that the base constructor needs to be called in the inherited class for this to work. This is true for all constructors provided by SqlObject

Instantiating by Column

An SqlObject can also be instantiated by identifying an entry by column. In the case that there are multiple results for the identifier, only the first one is mapped and returned.

[Table("[dbo].[tblDog]")]
public class Dog : SqlObject
{
    [Column("Owner")]
    public string Owner {get;set;}
    // ...
    public Dog(object value, string key, DatabaseConnector db): base(value, key, db) {}
}

public static class Main
{
    public static void Run()
    {
        using (var database = new DatabaseConnector("MyConnectionString"))
        {
            // Get a dog with Owner = Tom'
            var dog = new Dog("Tom", "Owner", database); 

            // Prints "Hi, my name is Owner!"
            Console.WriteLine($"Hi, my owner is {dog.Owner}!");
        }
    }
}

Instantiating with Values

In the case that a model should be instantiated with values instead of directly from a database, this may be done by passing a Dictionary into its constructor:

using (var database = new DatabaseConnector("MyConnectionString"))
{
    //Get all entries from a table
    var command = $"select * from {new Dog().GetTable()}";
    var response = (List<Dictionary<string, object>>) database.RunCommand(command, complex:true);
    
    Console.WriteLine("This is a list of dogs.");
    foreach (var item in response)
    {
        // Instantiate Dog with a dictionary
        var dog = new Dog(item);
        
        Console.WriteLine(dog.Name);
    }
}

NOTE: The code above creates a List of Dog objects, which may also be achieved with the SqlSelector class.

Instantiating without Values

An SqlObject may also be instantiated without any arguments:

Dog dog = new Dog();

This may be useful when creating new entries for a table that do not have values at the time of creation.

Reading a Model

An SqlObject has several built-in methods that are useful in interacting with it.

  • LoadValues() Loads all the values from a Dictionary into a model
  • LogValues() Is a method for debugging that logs all properties in an SqlObject
  • GetAllValues() Returns a Dictionary of all the properties of the model corresponding to a column.
  • GetId() and GetTable() returns the value of the Table and Id annotations of the model, which may be used for encapsulation of the model.
  • BuildAllRequest() returns an Sql query which selects all rows in a table and returns all values with a corresponding property in the model.

Modifying a Database

SqlObject has built in functions that allow it to create an instance of itself in an Sql database, or update an existing entry corresponding to its key column.

using (var database = new DatabaseConnector("MyConnectionString"))
{
    // Create a new Dog
    var dog = new Dog();
    dog.Owner = "Scott";
    dog.Name = "Spot";

    // Add the dog to a database
    dog.Create(database);

    // Change a value
    dog.Owner = "Matthew";

    // Update a value by column
    dog.SetValue("Owner", "Tom");

    // Get a value by column
    int age = dog.GetInt("Age");

    // Get the name or value of the Id column
    dog.GetId();
    dog.GetIdValue();

    // Update the exisitng entry in a database
    dog.Update(database);
    
    // Delete an entry in a database, by ID
    dog.Delete(database);
}

Using PartialSqlObject

There are some cases in which column values need to be stored, but their names might be uncertain, or they are not used actively in a model (Eg. an API service which might need to select all columns for an entry, but does not reference them internally).

In such cases, PartialSqlObject may be used instead of SqlObject to reduce the amount of boilerplate code that is required.

PartialSqlObject is an extension of SqlObject that selects ALL(*) columns in a table when creating an object, and stores them regardless of whether they correspond to a property in the model. This means that GetAllValues() returns the full result of the table without needing to define unused properties.

There is also a further extension of PartialSqlObject which may be used for dynamic table names or key columns, and entirely removes the need for extension before it is used.

[Table("[dbo].[tblDog]")]
public class Dog : PartialSqlObject
{
    [Id, Column("Name")]
    public string Name {get;set;}
    public Dog(object value, DatabaseConnector db): base(value, db) {}
}

public static class Main
{
    public static void Run()
    {
        using (var database = new DatabaseConnector("MyConnectionString"))
        {
            // Get a dog with Name = Spot'
            Dog dog = new Dog("Spot", database); 

            // Modify its properties
            dog.Name = "Spotto";
            
            // Get all its values and print them
            // The output will have ALL the columns from [tblDog]
            // Its new Name property will also be reflected
            Dictionary<string, object> values = dog.GetAllValues();
            foreach (string key in values.Keys)
            {
                Console.WriteLine($"{key}: {values[key]}");
            }

            // Access values from the object even without a defined property
            Console.WriteLine($"Hi! My age is {dog.GetInt("Age")}");
            Console.WriteLine($"Hi! My owner is {dog.GetString("Owner")}");

            // Set values in the object even without a defined property
            dog.SetValue("Weight", 33.5);
        }
    }
}

Using GenericSqlObject

For objects that may belong to dynamic tables or databases with uncertain keys, GenericSqlObject is a further extension of PartialSqlObject that entirely removes the need for a class to be defined with attributes before using it.

// This method gets an unknown table and looks under the specified field for an object owned by "James"

public void UnknownTable(string ownerColumn, string tableName)
{
    using (var database = new DatabaseConnector("MyConnectionString"))
    {
        // This constructor accepts a table and key, followed by the same values required to instantiate an SqlObject by column
        // Build a sample object with tableName and unspecified key
        // Load values from the database for an object with the owner column being "James"
        var unknownObject =  new GenericSqlObject(tableName, null, ownerColumn, "James");

        // Access and set values from the object even without a defined property
        // These methods are inherited from PartialSqlObject
        Console.WriteLine($"Hi! I'm changing my owner from {unknownObject.GetString(ownerColumn)} to Marnie!");
        unknownObject.SetValue(ownerColumn, "Marnie");
    }
}

In the implementation of a simple GetAll() method which returns all the values from an unknown table, GenericSqlObject may be used as a token and passed into SqlSelector to read all the values efficiently:

public List<Dictionary<string, object>> GetAll(string tableName)
{
    using (var database = new DatabaseConnector("MyConnectionString"))
    {
        var objectToken = new GenericSqlObject();
        objectToken.Table = tableName;

        var selector = new SqlSelector();

        // Since no parameters are specified for the select, all rows in the table are returned.
        List<SqlObject> objects = selector.BuildObjects(objectToken, database);

       // Return all the values as a List of Dictionary values
       return objects.select(o => o.GetAllValues());
    }
}

GenericSqlObject may also be extended in instances where there are a great number of tables with similar function such that the same methods may be shared over many instances of different tables, without the need to define classes for each of them specifically.

SqlObject Documentation

namespace Truffle.Model

SqlObject

public abstract class SqlObject

Subclasses
PartialSqlObject, GenericSqlObject

Constructors

Modifier Constructor Description
public SqlObject() Initialises a new instance of an SqlObject.
SqlObject(object id, DatabaseConnector database) Retrieves a row from an SQL database by Id and initialises itself with its values.
SqlObject(object value, string column, DatabaseConnector database) Retrieves the first instance of a row from an SQL database with the corresponding column value and initialises itself with its values.
SqlObject(Dictionary<string, object> values) Initialises an SqlObject with values from a dictionary.

Method Summary

Modifier and Type Method Summary
protected Dictionary<string, PropertyInfo> GetColumns<T> Returns a column-property dictionary of values.
protected void InitFromDatabase(object value, string column, DatabaseConnector database) Initialises itself with an entry from a database based on a column-value pair.
public virtual void LoadValues(Dictionary<string, object>) Initialises itself with values from a dictionary.
protected string BuildRequest(object value, string column) Builds a select string for the first entry in a database with a matching column-value pair.
public string BuildAllRequest(int top=-1, string orderBy=null) Builds a string that selects all entries from a table.
public virtual string BuildColumnSelector() Builds a comma-separated list of columns in this object.
public bool Equals(SqlObject o) Compares all values in the object and returns if they are equal to the values in this object.
public void Clean() Checks all columns for DataCleanerAttribute and converts any data that should be cleaned.
public void Validate() Checks all columns for DataValidatorAttribute and throws an error if any validation fails.
public virtual string GetId() Returns the name of the Id column for the object. If no property has been marked with the Id Attribute, this returns null.
public virtual object GetIdValue() Returns the current value of the property representing the Id of the object.
public virtual object GetValue(string column) Gets the value of a column in the object.
public virtual string SetValue(string column, object o) Sets the value of a column in the object.
public virtual bool GetBoolean(string column) Gets the boolean value of a column in the object.
public virtual string GetString() Gets the string value of a column in the object.
public virtual DateTime? GetDate() Gets the date value of a column in the object.
public virtual int GetInt() Gets the int value of a column in the object.
public virtual double GetDouble() Gets the double value of a column in the object.
public virtual Dictionary<string, object> GetAllValues(bool ignoreIdentities=false) Returns a Dictionary with all values currently held within the SqlObject.
public virtual void LogValues() Logs all keys, values, and types currently stored in the object with Console#WriteLine.
public virtual void Create(DatabaseConnector database, bool validate=true) Creates a new entry in a database with values stored in this object.
public virtual async Task CreateAsync(DatabaseConnector database, bool validate=true) Asynchronously creates a new entry in a database with values stored in this object.
public virtual void Update(DatabaseConnector database, bool validate=true) Updates an existing entry with a corresponding Id value in an SQL database with values stored in this object.
public virtual Task UpdateAsync(DatabaseConnector database, bool validate=true) Updates an existing entry with a corresponding Id value in an SQL database with values stored in this object.
public virtual void Delete(DatabaseConnector database) Deletes an existing entry from a database based on Id
public virtual Task DeleteAsync(DatabaseConnector database) Asynchronously deletes an existing entry from a database based on Id
public virtual T CreateEditor<T>(bool validate=true) Instantiates an SqlEditor and loads values from this object into it.

InitFromDatabase()

protected void InitFromDatabase(object value, string column, DatabaseConnector database)

Identifies the first instance of a row from an SQL database with the corresponding column and value and initialises itself with its values.

The SQL query is created with BuildRequest() and values are initialised with LoadValues()

Parameters

  • value - The value of the column
  • column - The name of the column
  • database - The database to retrieve from

BuildRequest()

protected string BuildRequest(object value, string column)

Builds a select string for the first entry in a database with a matching column-value pair.

    SELECT TOP 1 Owner, Name, Age, Breed FROM [dbo].[tblDog] where Name='Spot'

The columns are selected with BuildColumnSelector() and do not include columns that are not explicitly stated in the model.

NOTE: This behavior is overriden in PartialSqlObject to return all columns from a table.

Parameters

  • value - The value of the column
  • column - The name of the column

BuildAllRequest()

public string BuildAllRequest(int top = -1, string orderBy = null)

Builds a string that selects all entries from a table.

    SELECT Owner, Name, Age, Breed FROM [dbo].[tblDog]

The columns are selected with BuildColumnSelector() and do not include columns that are not explicitly stated in the model.

NOTE: This behavior is overriden in PartialSqlObject to return all columns from a table.

Parameters

  • top - If set, limits the number of returned rows
  • orderBy - If set, orders the returned values by a specified column

BuildColumnSelector

public virtual string BuildColumnSelector()

Builds a comma-separated list of columns represented by this object.

    Owner, Name, Age, Breed

This behavior is overriden in PartialSqlObject to return * instead, representing all columns.


Selecting from a Table

Truffle provides an SqlSelector class which provides methods to build a select command with specific parameters and columns. This class may be used in conjunction with SqlUpdater to update columns with specific parameters.

Usage:

// Create an SQL selector
SqlSelector selector = new SqlSelector();

// Select rows where breed = "Golden Retriever"
selector.Set("breed", "Golden Retriever");

// Select rows where name is NOT spot.
// This optional argument is present in all "Set" methods
selector.Set("name", "Spot", not:true);

// Select rows where the name contains the string "ark" like "Mark" or "Spark"
selector.SetLike("name", "ark")

// Select rows where the house is not null
selector.NotNull("house");

// Select rows where age is between 3 and 5. 
// A SetBetween() method is also provided that has the same function
int[] ages = {3,5};
selector.Set("age", ages);

// Select multiple parameters at once by passing in a dictionary
var values = new Dictionary<string, object>();
values.Add("owner", "tom");
values.Add("weight", new int[] {10, 15})
selector.SetAll(values);

// Get the string from the selector that returns columns name and owner
string cmd = selector.BuildSelect("[dbo].[tblDog]", "name, owner");
var result = database.RunCommand(cmd);

On top of the BuildSelect() method, SqlSelector is also able to directly parse select results into SqlObjects with its asynchronous BuildObjects method:

// Create an SQL selector
var selector = new SqlSelector();

// Select rows where breed = "Golden Retriever"
selector.Set("breed", "Golden Retriever");

// Select rows where age is between 3 and 5
// SetBetween() is a method with similar function
int[] ages = {3,5};
selector.Set("age", ages);

// Select rows where owner contains a string "hard", such as "richard" or "hardy"
selector.setLike("owner", "hard");

// Parse all the results into a list of SqlObjects
// This method requires the instantiated class to have a constructor that takes no arguments.
List<Dog> result = await selector.BuildObjects<Dog>(database);

Additional Options

SqlSelector has several other optional arguments that can be set during the building of the SQL select string:

  • top: int - if set, only returns the first n results in the string
  • distinct: bool - whether only distinct values should be returned
  • orderBy: string - accepts a string to order the results by eg. orderby: "Owner ASC" would order results by "Owner" in ascending order

Most of these arguments are modelled after their corresponding keywords in the SQL query, and should be intuitive to users of SQL.

Chaining SqlSelectors

For more advanced select queries that may require nested OR/AND conditionals, SqlSelectors can be chained to combine their select strings:

// A selector that looks for dogs in an age and weight range
var sizeSelector = new SqlSelector()
    .Set("age", 3)
    .SetBetween(10, 15, "weight");

// A selector that looks for dogs owned by richard
var richardSelector = new SqlSelector()
    .Set("owner", "richard");

// A selector that looks for dogs owned by ben
var benSelector = new SqlSelector()
    .Set("owner", "ben");

// Combine the selectors to select dogs owned by richard or ben with a certain weight and age
sizeSelector.And(richardSelector.Or(benSelector));

return sizeSelector;

Deleting From a Table

SqlSelector can be used to create delete queries when provided with similar parameters to BuildSelect():

// Create an SQL selector
SqlSelector selector = new SqlSelector();

// Select rows where breed = "Golden Retriever"
selector.Set("breed", "Golden Retriever");

// Get the delete string from the selector
string cmd = selector.BuildDelete("[dbo].[tblDog]", "name, owner");
var result = database.RunCommand(cmd);
}

Chaining SqlSelectors

For more advanced select queries that may require nested OR/AND conditionals, SqlSelectors can be chained to combine their select strings:

Updating a table

Truffle provides an SqlUpdater class which provides flexible formats to update a table:

// Create an SQL updater and sets its target to rows where Name='Spot'
var updater = new SqlUpdater("Spot", "Name");

// Add values for the updater to set
updater.Set("Age", 3);
updater.Set("Owner", "Mike");

// Update the corresponding table in the database with new values
updater.Update("[dbo].[tblDog]", database);
}

SqlUpdater also directly accepts an SqlObject and will update all of its values accordingly:

// Instantiates a Dog from the database
var dog = new Dog("Spot", database);

// Change values
dog.Owner = "Mike";

// Create an SQL updater and sets its target to rows where Name='Spot'
var updater = new SqlUpdater(dog);

// Update the corresponding table in the database with new values
updater.Update(dog.GetTable(), database);
}

Updating With SqlSelector

In the case that items with specific parameters need to be updated, it is also possible to directly pass an SqlSelector into SqlUpdater:

// Instantiate an SqlSelector and set its selection to ages between 1 and 2
var selector = new SqlSelector();
selector.SetBetween(1, 2, "age");

// Create an SQL updater with the SqlSelector
var updater = new SqlUpdater(selector);
updater.Set("Owner", "Local Pet Store");

// Updates all corresponding rows in the database with new values
updater.Update(dog.GetTable(), database);

Inserting to a Table

Truffle provides an SqlInserter class which provides flexible formats to update a table, in similar fashion to SqlUpdater:

// Create an SQL inserter
var inserter = new SqlInserter();

// Add values for the inserter to set
inserter.Set("Name", "Ruff");
inserter.Set("Age", 3);
inserter.Set("Owner", "Mike");

// Update the corresponding table in the database with new values
inserter.Insert("[dbo].[tblDog]", database);
}

SqlInserter may also be instantiated with an SqlObject with similar behaviour to SqlUpdater.

Data Validation in Truffle

Truffle allows data to be validated and/or cleaned before it is entered or updated in a database through the use of data validation attributes.

There are two forms of validation in Truffle:

  1. Data Cleaning, which converts values to other formats such as rounding numbers or simplifying strings, as defined by the DataCleanerAttribute class.
  2. Data Validation, which returns whether values are valid, as defined by the DataValidationAttribute class

While these validations are automatically called before an SqlObject is inserted or updated in a database, they may also be called manually with methods Clean() and Validate().

Adding Validation

To use data validation, append their corresponding attributes to properties in your SqlObject model:

[Table("[dbo].[tblDog]")]
public class Dog : SqlObject
{
    // Only allows uppercase and lowercase letters, . / and -
    // Cannot be null or an empty string
    [Id, Column("Name"), SimpleString, Required]
    public string MyName {get;set;}

    // Rounds values to 2 decimal places
    [Column("Age"), Decimals(2)]
    public double Age {get;set;}

    // Converts value to a SimpleString, and turns any invalid characters to '-'
    [Column("Owner"), SimplifyString]
    public string Owner {get;set;}

    [Column("dob")]
    public DateTime DateOfBirth {get;set;}
}

These validations are then taken into account when entering or modifying data in the database.

Existing data cleaners:

  • DecimalsAttribute - rounds a value to a specified number of decimal places
  • SimplifyString - converts any invalid characters (not an uppercase or lowercase letter and not . / or -) into dashes

Exiting data validators:

  • SimpleString - checks if a string is a simple string (not an uppercase or lowercase letter and not . / or -)
  • Required - checks if a field is filled (not null or an empty string)
  • MinValue - checks if a value is above or equal to a minimum value
  • MaxValue - checks if a value is below or equal to a maximum value
  • RegexValidation - matches a field against a regular expression

Enabling and Disabling Validation

Validation for an SqlObject is on by default and can be turned off manually. If validation should be ignored for an action, this can be indicated by setting validate to false in relevant methods:

// All of these methods will ignore validation
dog.Update(database, validate:false);
dog.Create(database, validate:false);

var selector = new SqlSelector(dog, validate:false);
var updater = new SqlUpdater(dog, validate:false);

Writing Custom Validations

To write a custom validation, the DataValidatorAttribute or DataCleanerAttribute class can be extended:

// This validator only checks if a dog has an owner if its age is greater than 2
public class IfAge: DataValidatorAttribute
{
    public override bool Validate(string name, object value, SqlObject model)
    {
        var dog = (Dog model)
        if (dog.Age < 2 || value != null) return true;
        this.SetMessage("This dog is older and requires this field");
        return false;
    }
}

// This cleaner treats a string as a double and rounds it
public class StringDecimalsAttribute: DataCleanerAttribute
{
    private readonly int places;
    public StringDecimalsAttribute(int places)
    {
        this.places = places;
    }
    public override object Clean(string name, object value, SqlObject model)
    {
        if (value == null) return null;
        var str = value.ToString();
        
        // Convert the string to a double and round it with the Decimals attribute
        var val = double.Parse(str);
        var result = new DecimalsAttribute(places).Clean(val, model);

        // Convert the double back to a string and return it
        return result.ToString();
    }
}

Clean() and Validate() are both abstract methods that need to be implemented, and provide the main purpose of these classes to clean and validate data passed into them. Their methods additionally accept an SqlObject that allows them to reference other values in the object.

These attributes can then be used normally in your models:

[Table("[dbo].[tblDog]")]
public class Dog : SqlObject
{
    // Will require a name if Age > 2
    [Id, Column("Name"), IfAge]
    public string MyName {get;set;}

    [Column("Age"), Decimals(2)]
    public double Age {get;set;}

    // Rounds weight to 2 decimal places but stores it as a string
    [Column("Weight"), StringDecimals(2)]
    public string Weight {get;set;}

    [Column("Owner"), IfAge]
    public string Owner {get;set;}
}

Asynchronous Methods in Truffle

In addition to methods mentioned in this README, Truffle also provides asynchronous versions of most of its methods. Users can refer to the XML documentation in each class for more information on these methods.

NOTE: Running asynchronous methods in an SQL database may require you to enable MultipleActiveResultSets in your SQL connection string.

Additional Notes

  • Truffle is still under heavy development and all of its classes are still subject to change.
  • Truffle was created as a result of my work as a backend software developer, and still lacks many functions (which will be added when I need them).
  • While case sensitivity for inserts and selects are not an issue for Truffle, it must be strictly adhered to when using PartialSqlObject as it may cause unpredictable behaviour.
  • Planned additions (besides the obvious DELETE function) include an SqlObjectBuilder that would allow for even more flexible creation of SqlObjects.

Back to Top

About

Lightweight SQL management library for C#

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • C# 100.0%