devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

A Fast, Simple, Typed ORM for .NET

作者：羊村懒王 | 2024-03-30 05:52:39

赞

踩

fast, simple, typed orm for .net

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

Join the ServiceStack Google+ group or follow @servicestack for updates.

A Fast, Simple, Typed ORM for .NET

OrmLite's goal is to provide a convenient, DRY, config-free, RDBMS-agnostic typed wrapper that retains a high affinity with SQL, exposing intuitive APIs that generate predictable SQL and maps cleanly to (DTO-friendly) disconnected POCO's. This approach makes easier to reason-about your data access making it obvious what SQL is getting executed at what time, whilst mitigating unexpected behavior, implicit N+1 queries and leaky data access prevalent in Heavy ORMs.

OrmLite was designed with a focus on the core objectives:

  • Provide a set of light-weight C# extension methods around .NET's impl-agnostic System.Data.*interfaces

  • Map a POCO class 1:1 to an RDBMS table, cleanly by conventions, without any attributes required.

  • Create/Drop DB Table schemas using nothing but POCO class definitions (IOTW a true code-first ORM)

  • Simplicity - typed, wrist friendly API for common data access patterns.

  • High performance - with support for indexes, text blobs, etc.

  • Expressive power and flexibility - with access to IDbCommand and raw SQL

  • Cross platform - supports multiple dbs (currently: Sql Server, Sqlite, MySql, PostgreSQL, Firebird) running on both .NET and Mono platforms.

In OrmLite: 1 Class = 1 Table. There should be no surprising or hidden behaviour. Any non-scalar properties (i.e. complex types) are by default text blobbed in a schema-less text field using any of theavilable pluggable text serializers. Support for POCO-friendly references is also available to provide a convenient API to persist related models. Effectively this allows you to create a table from any POCO type and it should persist as expected in a DB Table with columns for each of the classes 1st level public properties.

Download

Download on NuGet

8 flavours of OrmLite is on NuGet:

Latest v4+ on NuGet is a commercial release with free quotas.

Docs and Downloads for older v3 BSD releases

Copying

Since September 2013, ServiceStack source code is available under GNU Affero General Public License/FOSS License Exception, see license.txt in the source. Alternative commercial licensing is also available.

Contributing

Contributors need to approve the Contributor License Agreement before submitting pull-requests, see the Contributing wiki for more details.

Examples

OrmLite's SQL Expression support lets you use LINQ-liked querying in all our providers. To give you a flavour here are some examples with their partial SQL output (using SqlServer dialect):

Querying with SELECT

  1. int agesAgo = DateTime.Today.AddYears(-20).Year;db.Select<Author>(q => q.Birthday >= new DateTime(agesAgo, 1, 1) 
  2.                     && q.Birthday <= new DateTime(agesAgo, 12, 31));

WHERE (("Birthday" >= '1992-01-01 00:00:00.000') AND ("Birthday" <= '1992-12-31 00:00:00.000'))

db.Select<Author>(q => Sql.In(q.City, "London", "Madrid", "Berlin"));

WHERE "JobCity" In ('London', 'Madrid', 'Berlin')

db.Select<Author>(q => q.Earnings <= 50);

WHERE ("Earnings" <= 50)

db.Select<Author>(q => q.Name.StartsWith("A"));

WHERE upper("Name") like 'A%'

db.Select<Author>(q => q.Name.EndsWith("garzon"));

WHERE upper("Name") like '%GARZON'

db.Select<Author>(q => q.Name.Contains("Benedict"));

WHERE upper("Name") like '%BENEDICT%'

db.Select<Author>(q => q.Rate == 10 && q.City == "Mexico");

WHERE (("Rate" = 10) AND ("JobCity" = 'Mexico'))

Right now the Expression support can satisfy most simple queries with a strong-typed API. For anything more complex (e.g. queries with table joins) you can still easily fall back to raw SQL queries as seen below.

Convenient common usage data access patterns

OrmLite also includes a number of convenient API's providing DRY, typed data access for common queries:

Person personById = db.SingleById<Person>(1);

SELECT "Id", "FirstName", "LastName", "Age" FROM "Person" WHERE "Id" = @Id

Person personByAge = db.Single<Person>(x => x.Age == 42);

SELECT TOP 1 "Id", "FirstName", "LastName", "Age" FROM "Person" WHERE ("Age" = 42)

int maxAgeUnder50 = db.Scalar<Person, int>(x => Sql.Max(x.Age), x => x.Age < 50);

SELECT Max("Age") FROM "Person" WHERE ("Age" < 50)

  1. int peopleOver40 = db.Scalar<int>(
  2.     db.From<Person>().Select(Sql.Count("*")).Where(q => q.Age > 40));

SELECT COUNT(*) FROM "Person" WHERE ("Age" > 40)

int peopleUnder50 = db.Count<Person>(x => x.Age < 50);

SELECT COUNT(*) FROM "Person" WHERE ("Age" < 50)

bool has42YearOlds = db.Exists<Person>(new { Age = 42 });

WHERE "Age" = @Age 

  1. List<string> results = db.Column<string>(db.From<Person>().Select(x => x.LastName)
  2.                          .Where(q => q.Age == 27));

SELECT "LastName" FROM "Person" WHERE ("Age" = 27)

  1. HashSet<int> results = db.ColumnDistinct<int>(db.From<Person>().Select(x => x.Age)
  2.                          .Where(q => q.Age < 50));

SELECT "Age" FROM "Person" WHERE ("Age" < 50)

  1. Dictionary<int,string> results = db.Dictionary<int, string>(
  2.     db.From<Person>().Select(x => new { x.Id, x.LastName }).Where(x => x.Age < 50));

SELECT "Id","LastName" FROM "Person" WHERE ("Age" < 50)

  1. Dictionary<int, List<string>> results = db.Lookup<int, string>(
  2.     db.From<Person>().Select(x => new { x.Age, x.LastName }).Where(q => q.Age < 50));

SELECT "Age","LastName" FROM "Person" WHERE ("Age" < 50)

INSERT, UPDATE and DELETEs

To see the behaviour of the different APIs, all examples uses this simple model

  1. public class Person{
  2.   public int Id { get; set; }
  3.   public string FirstName { get; set; }
  4.   public string LastName { get; set; }
  5.   public int? Age { get; set; }}

UPDATE

In its most simple form, updating any model without any filters will update every field, except the Idwhich is used to filter the update to this specific record:

db.Update(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27});

UPDATE "Person" SET "FirstName" = 'Jimi',"LastName" = 'Hendrix',"Age" = 27 WHERE "Id" = 1

If you supply your own where expression, it updates every field (inc. Id) but uses your filter instead:

db.Update(new Person { Id = 1, FirstName = "JJ" }, p => p.LastName == "Hendrix");

UPDATE "Person" SET "Id" = 1,"FirstName" = 'JJ',"LastName" = NULL,"Age" = NULL WHERE ("LastName" = 'Hendrix')

One way to limit the fields which gets updated is to use an Anonymous Type:

db.Update<Person>(new { FirstName = "JJ" }, p => p.LastName == "Hendrix");

Or by using UpdateNonDefaults which only updates the non-default values in your model using the filter specified:

db.UpdateNonDefaults(new Person { FirstName = "JJ" }, p => p.LastName == "Hendrix");

UPDATE "Person" SET "FirstName" = 'JJ' WHERE ("LastName" = 'Hendrix')

UpdateOnly

As updating a partial row is a common use-case in Db's, we've added a number of methods for just this purpose, named UpdateOnly.

The first expression in an UpdateOnly statement is used to specify which fields should be updated:

db.UpdateOnly(new Person { FirstName = "JJ" }, p => p.FirstName);

UPDATE "Person" SET "FirstName" = 'JJ'

  1. db.UpdateOnly(new Person { FirstName = "JJ", Age = 12 }, 
  2.     onlyFields: p => new { p.FirstName, p.Age });

UPDATE "Person" SET "FirstName" = 'JJ', "Age" = 12

When present, the second expression is used as the where filter:

  1. db.UpdateOnly(new Person { FirstName = "JJ" }, 
  2.     onlyFields: p => p.FirstName, 
  3.     where: p => p.LastName == "Hendrix");

UPDATE "Person" SET "FirstName" = 'JJ' WHERE ("LastName" = 'Hendrix')

Instead of using the expression filters above you can choose to use an ExpressionVisitor builder which provides more flexibility when you want to programatically construct the update statement:

  1. db.UpdateOnly(new Person { FirstName = "JJ", LastName = "Hendo" }, 
  2.   onlyFields: q => q.Update(p => p.FirstName));

UPDATE "Person" SET "FirstName" = 'JJ'

  1. db.UpdateOnly(new Person { FirstName = "JJ" }, 
  2.   onlyFields: q => 1.Update(p => p.FirstName).Where(x => x.FirstName == "Jimi"));

UPDATE "Person" SET "FirstName" = 'JJ' WHERE ("LastName" = 'Hendrix')

For the ultimate flexibility we also provide un-typed, string-based expressions. Use the .Params()extension method escape parameters (inspired by massive):

  1. db.Update<Person>(set: "FirstName = {0}".Params("JJ"), 
  2.                 where: "LastName = {0}".Params("Hendrix"));

Even the Table name can be a string so you perform the same update without requiring the Person model at all:

  1. db.Update(table: "Person", set: "FirstName = {0}".Params("JJ"), 
  2.           where: "LastName = {0}".Params("Hendrix"));

UPDATE "Person" SET FirstName = 'JJ' WHERE LastName = 'Hendrix'

INSERT

Insert's are pretty straight forward since in most cases you want to insert every field:

db.Insert(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27 });

INSERT INTO "Person" ("Id","FirstName","LastName","Age") VALUES (1,'Jimi','Hendrix',27)

But do provide an API that takes an Expression Visitor for the rare cases you don't want to insert every field

db.InsertOnly(new Person { FirstName = "Amy" }, q => q.Insert(p => new {p.FirstName}))

INSERT INTO "Person" ("FirstName") VALUES ('Amy')

DELETE

Like updates for DELETE's we also provide APIs that take a where Expression:

db.Delete<Person>(p => p.Age == 27);

Or an Expression Visitor:

db.Delete<Person>(q => q.Where(p => p.Age == 27));

DELETE FROM "Person" WHERE ("Age" = 27)

As well as un-typed, string-based expressions:

db.Delete<Person>(where: "Age = {0}".Params(27));

Which also can take a table name so works without requiring a typed Person model

db.Delete(table: "Person", where: "Age = {0}".Params(27));

DELETE FROM "Person" WHERE Age = 27

API Overview

The API is minimal, providing basic shortcuts for the primitive SQL statements:

OrmLite API

Notes

OrmLite Extension methods hang off ADO.NET's IDbConnection.

CreateTable<T> and DropTable<T> create and drop tables based on a classes type definition (only public properties used).

By default the Select API's use parameterized SQL whilst any selection methods ending with Fmtallow you to construct Sql using C# string.Format() syntax.

If your SQL doesn't start with a SELECT statement, it is assumed a WHERE clause is being provided, e.g:

  1. var tracks = db.SelectFmt<Track>("Artist = {0} AND Album = {1}", 
  2.   "Nirvana", 
  3.   "Heart Shaped Box");

Which is equivalent to:

  1. var tracks = db.SelectFmt<Track>("SELECT * FROM track WHERE Artist={0} AND Album={1}", 
  2.     "Nirvana", 
  3.     "Heart Shaped Box");

Select returns multiple records:

List<Track> tracks = db.Select<Track>()

Single returns a single record:

Track track = db.Single<Track>(q => q.RefId == refId)

Dictionary returns a Dictionary made from the first two columns:

  1. Dictionary<int, string> trackIdNamesMap = db.Dictionary<int, string>(
  2.     "select Id, Name from Track")

Lookup returns an Dictionary<K, List<V>> made from the first two columns:

  1. Dictionary<int, List<string>> albumTrackNames = db.Lookup<int, string>(
  2.     "select AlbumId, Name from Track")

Column returns a List of first column values:

List<string> trackNames = db.Column<string>("select Name from Track")

HashSet returns a HashSet of distinct first column values:

HashSet<string> uniqueTrackNames = db.ColumnDistinct<string>("select Name from Track")

Scalar returns a single scalar value:

var trackCount = db.Scalar<int>("select count(*) from Track")

Anonymous types passed into Where are treated like an AND filter:

var track3 = db.Where<Track>(new { AlbumName = "Throwing Copper", TrackNo = 3 })

Select statements take in parameterized SQL using properties from the supplied anonymous type (if any):

  1. var track3 = db.Select<Track>(
  2.   "select * from Track Where AlbumName = @album and TrackNo = @trackNo", 
  3.   new { album = "Throwing Copper", trackNo = 3 })

SingleById(s), SelectById(s), etc provide strong-typed convenience methods to fetch by a Table's Idprimary key field.

var track = db.SingleById<Track>(1);var tracks = db.SelectByIds<Track>(new[]{ 1,2,3 });

Other Notes

  • All Insert, Update, and Delete methods take multiple params, while InsertAll, UpdateAll andDeleteAll take IEnumerables.

  • Save and SaveAll will Insert if no record with Id exists, otherwise it Updates.

  • Methods containing the word Each return an IEnumerable and are lazily loaded (i.e. non-buffered).

Features

Whilst OrmLite aims to provide a light-weight typed wrapper around SQL, it offers a number of convenient features that makes working with RDBMS's a clean and enjoyable experience:

Typed SqlExpression support for JOIN's

Starting with the most basic example you can simply specify the table you want to join with:

var dbCustomers = db.Select<Customer>(q => q.Join<CustomerAddress>());

This query rougly maps to the following SQL:

  1. SELECT Customer.* 
  2.   FROM Customer 
  3.        INNER JOIN 
  4.        CustomerAddress ON (Customer.Id == CustomerAddress.Id)

Just like before q is an instance of SqlExpression<Customer> which is bounded to the base Customertype (and what any subsequent implicit API's apply to).

To better illustrate the above query, lets expand it to the equivalent explicit query:

SqlExpression<Customer> q = db.From<Customer>();q.Join<Customer,CustomerAddress>((cust,address) => cust.Id == address.CustomerId);List<Customer> dbCustomers = db.Select(q);

Reference Conventions

The above query implicitly joins together the Customer and CustomerAddress POCO's using the same{ParentType}Id property convention used in OrmLite's support for References, e.g:

  1. class Customer {
  2.     public Id { get; set; }
  3.     ...}class CustomerAddress {
  4.     public Id { get; set; }
  5.     public CustomerId { get; set; }  // Reference based on Property name convention}

References based on matching alias names is also supported, e.g:

  1. [Alias("LegacyCustomer")]class Customer {
  2.     public Id { get; set; }
  3.     ...}class CustomerAddress {
  4.     public Id { get; set; }    [Alias("LegacyCustomerId")]             // Matches `LegacyCustomer` Alias
  5.     public RenamedCustomerId { get; set; }  // Reference based on Alias Convention}

Self References

Self References are also supported for 1:1 relations where the Foreign Key can instead be on the parent table:

  1. public class Customer{
  2.     ...
  3.     public int CustomerAddressId { get; set; }    [Reference]
  4.     public CustomerAddress PrimaryAddress { get; set; }}

Foreign Key and References Attributes

References that don't follow the above naming conventions can be declared explicitly using the[References] and [ForeignKey] attributes:

  1. public class Customer{    [References(typeof(CustomerAddress))]
  2.     public int PrimaryAddressId { get; set; }    [Reference]
  3.     public CustomerAddress PrimaryAddress { get; set; }}

Reference Attributes take precedence over naming conventions

Implicit Reference Conventions are applied by default

The implicit relationship above allows you to use any of these equilvalent APIs to JOIN tables:

q.Join<CustomerAddress>();q.Join<Customer,CustomerAddress>();q.Join<Customer,CustomerAddress>((cust,address) => cust.Id == address.CustomerId);

Selecting multiple columns across joined tables

Another implicit behaviour when selecting from a typed SqlExpression is that results are mapped to theCustomer POCO. To change this default we just need to explicitly specify what POCO it should map to instead:

  1. List<FullCustomerInfo> customers = db.Select<FullCustomerInfo>(
  2.     db.From<Customer>().Join<CustomerAddress>());

Where FullCustomerInfo is any POCO that contains a combination of properties matching any of the joined tables in the query.

The above example is also equivalent to the shorthand db.Select<Into,From>() API:

var customers = db.Select<FullCustomerInfo,Customer>(q => q.Join<CustomerAddress>());

Rules for how results are mapped is simply each property on FullCustomerInfo is mapped to the first matching property in any of the tables in the order they were added to the SqlExpression.

The mapping also includes a fallback for referencing fully-qualified names in the format: {TableName}{FieldName} allowing you to reference ambiguous fields, e.g:

  • CustomerId => "Customer"."Id"

  • OrderId => "Order"."Id"

  • CustomerName => "Customer"."Name"

  • OrderCost => "Order"."Cost"

Advanced Example

Seeing how the SqlExpression is constructed, joined and mapped, we can take a look at a more advanced example to showcase more of the new API's available:

  1. List<FullCustomerInfo> rows = db.Select<FullCustomerInfo>(  // Map results to FullCustomerInfo POCO
  2.   db.From<Customer>()                                       // Create typed Customer SqlExpression
  3.     .LeftJoin<CustomerAddress>()                            // Implict left join with base table
  4.     .Join<Customer, Order>((c,o) => c.Id == o.CustomerId)   // Explicit join and condition
  5.     .Where(c => c.Name == "Customer 1")                     // Implicit condition on base table
  6.     .And<Order>(o => o.Cost < 2)                            // Explicit condition on joined Table
  7.     .Or<Customer,Order>((c,o) => c.Name == o.LineItem));    // Explicit condition with joined Tables

The comments next to each line document each Type of API used. Some of the new API's introduced in this example include:

  • Usage of LeftJoin for specifying a LEFT JOIN, RightJoin and FullJoin also available

  • Usage of And<Table>(), to specify an AND condition on a Joined table

  • Usage of Or<Table1,Table2>, to specify an OR condition against 2 joined tables

More code examples of References and Joined tables are available in:

Reference Support, POCO style

OrmLite lets you Store and Load related entities in separate tables using [Reference] attributes in primary tables in conjunction with {Parent}Id property convention in child tables, e.g:

  1. public class Customer{    [AutoIncrement]
  2.     public int Id { get; set; }
  3.     public string Name { get; set; }    [Reference] // Save in CustomerAddress table
  4.     public CustomerAddress PrimaryAddress { get; set; }    [Reference] // Save in Order table
  5.     public List<Order> Orders { get; set; }}public class CustomerAddress{    [AutoIncrement]
  6.     public int Id { get; set; }
  7.     public int CustomerId { get; set; } //`{Parent}Id` convention to refer to Customer
  8.     public string AddressLine1 { get; set; }
  9.     public string AddressLine2 { get; set; }
  10.     public string City { get; set; }
  11.     public string State { get; set; }
  12.     public string Country { get; set; }}public class Order{    [AutoIncrement]
  13.     public int Id { get; set; }
  14.     public int CustomerId { get; set; } //`{Parent}Id` convention to refer to Customer
  15.     public string LineItem { get; set; }
  16.     public int Qty { get; set; }
  17.     public decimal Cost { get; set; }}

With the above structure you can save a POCO and all its entity references withdb.Save(T,references:true), e.g:

  1. var customer =  new Customer {
  2.     Name = "Customer 1",
  3.     PrimaryAddress = new CustomerAddress {
  4.         AddressLine1 = "1 Australia Street",
  5.         Country = "Australia"
  6.     },
  7.     Orders = new[] {
  8.         new Order { LineItem = "Line 1", Qty = 1, Cost = 1.99m },
  9.         new Order { LineItem = "Line 2", Qty = 2, Cost = 2.99m },
  10.     }.ToList(),};db.Save(customer, references:true);

This saves the root customer POCO in the Customer table, its related PrimaryAddress in theCustomerAddress table and its 2 Orders in the Order table.

Querying POCO's with References

The Load* API's are used to automatically load a POCO and all it's child references, e.g:

var customer = db.LoadSingleById<Customer>(customerId);

Using Typed SqlExpressions:

var customers = db.LoadSelect<Customer>(q => q.Name == "Customer 1");

More examples available in LoadReferencesTests.cs

Unlike normal complex properties, references:

  • Doesn't persist as complex type blobs

  • Doesn't impact normal querying

  • Saves and loads references independently from itself

  • Are serializable with Text serializers (only populated are visible).

  • Loads related data only 1-reference-level deep

Basically they provides a better story when dealing with referential data that doesn't impact the POCO's ability to be used as DTO's.

Optimistic Concurrency

Optimistic concurrency can be added to any table by adding the ulong RowVersion { get; set; }property, e.g:

  1. public class Poco{
  2.     ...
  3.     public ulong RowVersion { get; set; }}

RowVersion is implemented efficiently in all major RDBMS's, i.e:

  • Uses rowversion datatype in SqlServer

  • Uses PostgreSql's xmin system column (no column on table required)

  • Uses UPDATE triggers on MySql, Sqlite and Oracle whose lifetime is attached to Create/Drop tables APIs

Despite their differing implementations each provider works the same way where the RowVersionproperty is populated when the record is selected and only updates the record if the RowVersion matches with what's in the database, e.g:

  1. var rowId = db.Insert(new Poco { Text = "Text" }, selectIdentity:true);var row = db.SingleById<Poco>(rowId);row.Text += " Updated";db.Update(row); //success!row.Text += "Attempting to update stale record";//Can't update stale recordAssert.Throws<OptimisticConcurrencyException>(() =>
  2.     db.Update(row));//Can update latest versionvar updatedRow = db.SingleById<Poco>(rowId);  // fresh versionupdatedRow.Text += "Update Success!";db.Update(updatedRow);updatedRow = db.SingleById<Poco>(rowId);db.Delete(updatedRow);                        // can delete fresh version

Optimistic concurrency is only verified on API's that update or delete an entire entity, i.e. it's not enforced in partial updates. There's also an Alternative API available for DELETE's:

db.DeleteById<Poco>(id:updatedRow.Id, rowversion:updatedRow.RowVersion)

Exec, Result and String Filters

OrmLite's core Exec filters makes it possible to inject your own behavior, tracing, profiling, etc.

It's useful in situations like wanting to use SqlServer in production but use an in-memory Sqlite database in tests and being able to emulate any missing SQL Server Stored Procedures in code:

  1. public class MockStoredProcExecFilter : OrmLiteExecFilter{
  2.     public override T Exec<T>(IDbConnection dbConn, Func<IDbCommand, T> filter)
  3.     {
  4.         try
  5.         {
  6.             return base.Exec(dbConn, filter);
  7.         }
  8.         catch (Exception ex)
  9.         {
  10.             if (dbConn.GetLastSql() == "exec sp_name @firstName, @age")
  11.                 return (T)(object)new Person { FirstName = "Mocked" };
  12.             throw;
  13.         }
  14.     }}OrmLiteConfig.ExecFilter = new MockStoredProcExecFilter();using (var db = OpenDbConnection()){
  15.     var person = db.SqlScalar<Person>("exec sp_name @firstName, @age",
  16.         new { firstName = "aName", age = 1 });
  17.  
  18.     person.FirstName.Print(); //Mocked}

Results filters makes it trivial to implement the CaptureSqlFilter which allows you to capture SQL Statements without running them, e.g:

  1. public class CaptureSqlFilter : OrmLiteResultsFilter{
  2.     public CaptureSqlFilter()
  3.     {
  4.         SqlFilter = CaptureSql;
  5.         SqlStatements = new List<string>();
  6.     }
  7.  
  8.     private void CaptureSql(string sql)
  9.     {
  10.         SqlStatements.Add(sql);
  11.     }
  12.  
  13.     public List<string> SqlStatements { get; set; }}

Which can be used to wrap around existing database calls to capture, defer or print generated SQL, e.g:

  1. using (var captured = new CaptureSqlFilter())using (var db = OpenDbConnection()){
  2.     db.CreateTable<Person>();
  3.     db.Count<Person>(x => x.Age < 50);
  4.     db.Insert(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix" });
  5.     db.Delete<Person>(new { FirstName = "Jimi", Age = 27 });
  6.  
  7.     var sql = string.Join(";\n", captured.SqlStatements.ToArray());
  8.     sql.Print();}

Mockable extension methods

The Result Filters also lets you easily mock results and avoid hitting the database, typically useful in Unit Testing Services to mock OrmLite API's directly instead of using a repository, e.g:

  1. using (new OrmLiteResultsFilter {
  2.     PrintSql = true,
  3.     SingleResult = new Person { 
  4.       Id = 1, FirstName = "Mocked", LastName = "Person", Age = 100 
  5.     },}){
  6.     db.Single<Person>(x => x.Age == 42).FirstName // Mocked
  7.     db.Single(db.From<Person>().Where(x => x.Age == 42)).FirstName // Mocked
  8.     db.Single<Person>(new { Age = 42 }).FirstName // Mocked
  9.     db.Single<Person>("Age = @age", new { age = 42 }).FirstName // Mocked}

More examples showing how to mock different API's including support for nesting available inMockAllApiTests.cs

String Filter

There's also a specific filter for strings available which allows you to apply custom sanitization on String fields, e.g. you can ensure all strings are right trimmed with:

OrmLiteConfig.StringFilter = s => s.TrimEnd();db.Insert(new Poco { Name = "Value with trailing   " });db.Select<Poco>().First().Name // "Value with trailing"

Pluggable Complex Type Serializers

Pluggable serialization lets you specify different serialization strategies of Complex Types for each available RDBMS provider, e.g:

//ServiceStack's JSON and JSV FormatSqliteDialect.Provider.StringSerializer = new JsvStringSerializer();       PostgreSqlDialect.Provider.StringSerializer = new JsonStringSerializer();//.NET's XML and JSON DataContract serializersSqlServerDialect.Provider.StringSerializer = new DataContractSerializer();MySqlDialect.Provider.StringSerializer = new JsonDataContractSerializer();//.NET XmlSerializerOracleDialect.Provider.StringSerializer = new XmlSerializableSerializer();

You can also provide a custom serialization strategy by implementing IStringSerializer.

By default all dialects use the existing JsvStringSerializer, except for PostgreSQL which due to its built-in support for JSON, uses the JSON format by default.

Global Insert / Update Filters

Similar to interceptors in some heavy ORM's, Insert and Update filters get fired just before anyINSERT or UPDATE operation using OrmLite's typed API's (i.e. not dynamic SQL or partial updates using anon types). This functionality can be used for easily auto-maintaining Audit information for your POCO data models, e.g:

  1. public interface IAudit {
  2.     DateTime CreatedDate { get; set; }
  3.     DateTime ModifiedDate { get; set; }
  4.     string ModifiedBy { get; set; }}OrmLiteConfig.InsertFilter = (dbCmd, row) => {
  5.     var auditRow = row as IAudit;
  6.     if (auditRow != null)
  7.         auditRow.CreatedDate = auditRow.ModifiedDate = DateTime.UtcNow;};OrmLiteConfig.UpdateFilter = (dbCmd, row) => {
  8.     var auditRow = row as IAudit;
  9.     if (auditRow != null)
  10.         auditRow.ModifiedDate = DateTime.UtcNow;};

Which will ensure that the CreatedDate and ModifiedDate fields are populated on every insert and update.

Validation Example

The filters can also be used for validation where throwing an exception will prevent the operation and bubble the exception, e.g:

  1. OrmLiteConfig.InsertFilter = OrmLiteConfig.UpdateFilter = (dbCmd, row) => {
  2.     var auditRow = row as IAudit;
  3.     if (auditRow != null && auditRow.ModifiedBy == null)
  4.         throw new ArgumentNullException("ModifiedBy");};try{
  5.     db.Insert(new AuditTable());}catch (ArgumentNullException) {
  6.    //throws ArgumentNullException}db.Insert(new AuditTable { ModifiedBy = "Me!" }); //succeeds

Custom SQL Customizations

A number of new hooks are available to provide more flexibility when creating and dropping your RDBMS tables.

Custom Field Declarations

The [CustomField] attribute can be used for specifying custom field declarations in the generated Create table DDL statements, e.g:

  1. public class PocoTable{
  2.     public int Id { get; set; }    [CustomField("CHAR(20)")]
  3.     public string CharColumn { get; set; }    [CustomField("DECIMAL(18,4)")]
  4.     public decimal? DecimalColumn { get; set; }}db.CreateTable<PocoTable>();

Generates and executes the following SQL:

  1. CREATE TABLE "PocoTable" (
  2.   "Id" INTEGER PRIMARY KEY, 
  3.   "CharColumn" CHAR(20) NULL, 
  4.   "DecimalColumn" DECIMAL(18,4) NULL );
Pre / Post Custom SQL Hooks when Creating and Dropping tables

Pre / Post Custom SQL Hooks allow you to inject custom SQL before and after tables are created or dropped, e.g:

  1. [PostCreateTable("INSERT INTO TableWithSeedData (Name) VALUES ('Foo');" +                 "INSERT INTO TableWithSeedData (Name) VALUES ('Bar');")]public class TableWithSeedData{    [AutoIncrement]
  2.     public int Id { get; set; }
  3.     public string Name { get; set; }}

Which like other ServiceStack attributes, can also be added dynamically, e.g:

  1. typeof(TableWithSeedData)
  2.     .AddAttributes(new PostCreateTableAttribute(
  3.         "INSERT INTO TableWithSeedData (Name) VALUES ('Foo');" +
  4.         "INSERT INTO TableWithSeedData (Name) VALUES ('Bar');"));

Custom SQL Hooks also allow executing custom SQL before and after a table has been created or dropped, i.e:

[PreCreateTable(runSqlBeforeTableCreated)][PostCreateTable(runSqlAfterTableCreated)][PreDropTable(runSqlBeforeTableDropped)][PostDropTable(runSqlAfterTableDropped)]public class Table {}

Untyped API support

The IUntypedApi interface is useful for when you only have access to a late-bound object runtime type which is accessible via db.CreateTypedApi, e.g:

  1. public class BaseClass{
  2.     public int Id { get; set; }}public class Target : BaseClass{
  3.     public string Name { get; set; }}var row = (BaseClass)new Target { Id = 1, Name = "Foo" };var useType = row.GetType();var typedApi = db.CreateTypedApi(useType);db.DropAndCreateTables(useType);typedApi.Save(row);var typedRow = db.SingleById<Target>(1);typedRow.Name //= Foovar updateRow = (BaseClass)new Target { Id = 1, Name = "Bar" };typedApi.Update(updateRow);typedRow = db.SingleById<Target>(1);typedRow.Name //= BartypedApi.Delete(typedRow, new { Id = 1 });typedRow = db.SingleById<Target>(1); //= null

T4 Template Support

OrmLite's T4 Template are useful in database-first development or when wanting to use OrmLite with an existing RDBMS by automatically generating POCO's and strong-typed wrappers for executing stored procedures.

OrmLite's T4 support can be added via NuGet with:

PM> Install-Package ServiceStack.OrmLite.T4

Typed SqlExpressions with Custom SQL APIs

The Custom SQL API's allow you to map custom SqlExpressions into different responses:

  1. List<Person> results = db.SqlList<Person>(
  2.     db.From<Person>().Select("*").Where(q => q.Age < 50));List<Person> results = db.SqlList<Person>(
  3.     "SELECT * FROM Person WHERE Age < @age", new { age=50});List<string> results = db.SqlColumn<string>(db.From<Person>().Select(x => x.LastName));List<string> results = db.SqlColumn<string>("SELECT LastName FROM Person");HashSet<int> results = db.ColumnDistinct<int>(db.From<Person>().Select(x => x.Age));HashSet<int> results = db.ColumnDistinct<int>("SELECT Age FROM Person");int result = db.SqlScalar<int>(
  4.     db.From<Person>().Select(Sql.Count("*")).Where(q => q.Age < 50));int result = db.SqlScalar<int>("SELCT COUNT(*) FROM Person WHERE Age < 50");

Stored Procedures using Custom Raw SQL API's

The Raw SQL API's provide a convenient way for mapping results of any Custom SQL like executing Stored Procedures:

  1. List<Poco> results = db.SqlList<Poco>("EXEC GetAnalyticsForWeek 1");List<Poco> results = db.SqlList<Poco>(
  2.     "EXEC GetAnalyticsForWeek @weekNo", new { weekNo = 1 });List<int> results = db.SqlList<int>("EXEC GetTotalsForWeek 1");List<int> results = db.SqlList<int>(
  3.     "EXEC GetTotalsForWeek @weekNo", new { weekNo = 1 });int result = db.SqlScalar<int>("SELECT 10");

Stored Procedures with output params

The SqlProc API provides even greater customization by letting you modify the underlying ADO.NET Stored Procedure call by returning a prepared IDbCommand allowing for advanced customization like setting and retriving OUT parameters, e.g:

string spSql = @"DROP PROCEDURE IF EXISTS spSearchLetters;    CREATE PROCEDURE spSearchLetters (IN pLetter varchar(10), OUT pTotal int)    BEGIN        SELECT COUNT(*) FROM LetterFrequency WHERE Letter = pLetter INTO pTotal;        SELECT * FROM LetterFrequency WHERE Letter = pLetter;    END";db.ExecuteSql(spSql);var cmd = db.SqlProc("spSearchLetters", new { pLetter = "C" });var pTotal = cmd.AddParam("pTotal", direction: ParameterDirection.Output);var results = cmd.ConvertToList<LetterFrequency>();var total = pTotal.Value;

An alternative approach is to use SqlList which lets you use a filter to customize a Stored Procedure or any other command type, e.g:

  1. IDbDataParameter pTotal = null;var results = db.SqlList<LetterFrequency>("spSearchLetters", cmd => {
  2.         cmd.CommandType = CommandType.StoredProcedure;
  3.         cmd.AddParam("pLetter", "C");
  4.         pTotal = cmd.AddParam("pTotal", direction: ParameterDirection.Output);
  5.     });var total = pTotal.Value;

More examples can be found in SqlServerProviderTests.

New Foreign Key attribute for referential actions on Update/Deletes

Creating a foreign key in OrmLite can be done by adding [References(typeof(ForeignKeyTable))] on the relation property, which will result in OrmLite creating the Foreign Key relationship when it creates the DB table with db.CreateTable<Poco>. @brainless83 has extended this support further by adding more finer-grain options and behaviours with the new [ForeignKey] attribute which will now let you specify the desired behaviour when deleting or updating related rows in Foreign Key tables.

An example of a table with all the different options:

  1. public class TableWithAllCascadeOptions{    [AutoIncrement] public int Id { get; set; }    [References(typeof(ForeignKeyTable1))]
  2.     public int SimpleForeignKey { get; set; }    [ForeignKey(typeof(ForeignKeyTable2), OnDelete = "CASCADE", OnUpdate = "CASCADE")]
  3.     public int? CascadeOnUpdateOrDelete { get; set; }    [ForeignKey(typeof(ForeignKeyTable3), OnDelete = "NO ACTION")]
  4.     public int? NoActionOnCascade { get; set; }    [Default(typeof(int), "17")]    [ForeignKey(typeof(ForeignKeyTable4), OnDelete = "SET DEFAULT")]
  5.     public int SetToDefaultValueOnDelete { get; set; }    [ForeignKey(typeof(ForeignKeyTable5), OnDelete = "SET NULL")]
  6.     public int? SetToNullOnDelete { get; set; }}

The ForeignKeyTests show the resulting behaviour with each of these configurations in more detail.

Note: Only supported on RDBMS's with foreign key/referential action support, e.g. Sql Server,PostgreSQL, MySQL. Otherwise they're ignored.

Multi nested database connections

We now support multiple nested database connections so you can now trivially use OrmLite to access multiple databases on different connections. The OrmLiteConnectionFactory class has been extended to support named connections which allows you to conveniently define all your db connections when you register it in your IOC and access them with the named property when you use them.

A popular way of scaling RDBMS's is to create a Master / Shard setup where datasets for queries that span entire system are kept in the master database, whilst context-specific related data can be kept together in an isolated shard. This feature makes it trivial to maintain multiple separate db shards with a master database in a different RDBMS.

Here's an (entire source code) sample of the code needed to define, and populate a Master/Shard setup. Sqlite can create DB shards on the fly so only the blank SqlServer master database needed to be created out-of-band:

Sharding 1000 Robots into 10 Sqlite DB shards - referencing each in a Master SqlServer RDBMS

  1. public class MasterRecord {
  2.     public Guid Id { get; set; }
  3.     public int RobotId { get; set; }
  4.     public string RobotName { get; set; }
  5.     public DateTime? LastActivated { get; set; }}public class Robot {
  6.     public int Id { get; set; }
  7.     public string Name { get; set; }
  8.     public bool IsActivated { get; set; }
  9.     public long CellCount { get; set; }
  10.     public DateTime CreatedDate { get; set; }}const int NoOfShards = 10;const int NoOfRobots = 1000;var dbFactory = new OrmLiteConnectionFactory(
  11.     "Data Source=host;Initial Catalog=RobotsMaster;Integrated Security=SSPI",  //Connection String
  12.     SqlServerDialect.Provider); dbFactory.Run(db => db.CreateTable<MasterRecord>(overwrite:false));NoOfShards.Times(i => {
  13.     var namedShard = "robots-shard" + i;
  14.     dbFactory.RegisterConnection(namedShard, 
  15.         "~/App_Data/{0}.sqlite".Fmt(shardId).MapAbsolutePath(),                //Connection String
  16.         SqliteDialect.Provider);
  17.  
  18.     dbFactory.OpenDbConnection(namedShard).Run(db => db.CreateTable<Robot>(overwrite:false));});var newRobots = NoOfRobots.Times(i => //Create 1000 Robots
  19.     new Robot { Id=i, Name="R2D"+i, CreatedDate=DateTime.UtcNow, CellCount=DateTime.Now.ToUnixTimeMs() % 100000 });foreach (var newRobot in newRobots) {
  20.     using (IDbConnection db = dbFactory.OpenDbConnection()) //Open Connection to Master DB 
  21.     {
  22.         db.Insert(new MasterRecord { Id = Guid.NewGuid(), RobotId = newRobot.Id, RobotName = newRobot.Name });
  23.         using (IDbConnection robotShard = dbFactory.OpenDbConnection("robots-shard"+newRobot.Id % NoOfShards)) //Shard
  24.         {
  25.             robotShard.Insert(newRobot);
  26.         }
  27.     }}

Using the SQLite Manager Firefox extension we can peek at one of the created shards to see 100 Robots in each shard. This is the dump of robots-shard0.sqlite:

Data dump of Robot Shard #1

As expected each shard has every 10th robot inside.

Code-first Customer & Order example with complex types on POCO as text blobs

Below is a complete stand-alone example. No other config or classes is required for it to run. It's also available as a stand-alone unit test.

  1. public enum PhoneType {
  2.     Home,
  3.     Work,
  4.     Mobile,}public enum AddressType {
  5.     Home,
  6.     Work,
  7.     Other,}public class Address {
  8.     public string Line1 { get; set; }
  9.     public string Line2 { get; set; }
  10.     public string ZipCode { get; set; }
  11.     public string State { get; set; }
  12.     public string City { get; set; }
  13.     public string Country { get; set; }}public class Customer {
  14.     public Customer() {
  15.         this.PhoneNumbers = new Dictionary<PhoneType, string>();
  16.         this.Addresses = new Dictionary<AddressType, Address>();
  17.     }    [AutoIncrement] // Creates Auto primary key
  18.     public int Id { get; set; }
  19.  
  20.     public string FirstName { get; set; }
  21.     public string LastName { get; set; }    [Index(Unique = true)] // Creates Unique Index
  22.     public string Email { get; set; }
  23.  
  24.     public Dictionary<PhoneType, string> PhoneNumbers { get; set; }  //Blobbed
  25.     public Dictionary<AddressType, Address> Addresses { get; set; }  //Blobbed
  26.     public DateTime CreatedAt { get; set; }}public class Order {    [AutoIncrement]
  27.     public int Id { get; set; }    [References(typeof(Customer))]      //Creates Foreign Key
  28.     public int CustomerId { get; set; }    [References(typeof(Employee))]      //Creates Foreign Key
  29.     public int EmployeeId { get; set; }
  30.  
  31.     public Address ShippingAddress { get; set; } //Blobbed (no Address table)
  32.  
  33.     public DateTime? OrderDate { get; set; }
  34.     public DateTime? RequiredDate { get; set; }
  35.     public DateTime? ShippedDate { get; set; }
  36.     public int? ShipVia { get; set; }
  37.     public decimal Freight { get; set; }
  38.     public decimal Total { get; set; }}public class OrderDetail {    [AutoIncrement]
  39.     public int Id { get; set; }    [References(typeof(Order))] //Creates Foreign Key
  40.     public int OrderId { get; set; }
  41.  
  42.     public int ProductId { get; set; }
  43.     public decimal UnitPrice { get; set; }
  44.     public short Quantity { get; set; }
  45.     public decimal Discount { get; set; }}public class Employee {
  46.     public int Id { get; set; }
  47.     public string Name { get; set; }}public class Product {
  48.     public int Id { get; set; }
  49.     public string Name { get; set; }
  50.     public decimal UnitPrice { get; set; }}//Setup SQL Server Connection Factoryvar dbFactory = new OrmLiteConnectionFactory(
  51.     @"Data Source=.\SQLEXPRESS;AttachDbFilename=|DataDirectory|\App_Data\Database1.mdf;Integrated Security=True;User Instance=True",
  52.     SqlServerDialect.Provider);//Use in-memory Sqlite DB instead//var dbFactory = new OrmLiteConnectionFactory(//    ":memory:", false, SqliteDialect.Provider);//Non-intrusive: All extension methods hang off System.Data.* interfacesusing (IDbConnection db = Config.OpenDbConnection()){
  53.   //Re-Create all table schemas:
  54.   db.DropTable<OrderDetail>();
  55.   db.DropTable<Order>();
  56.   db.DropTable<Customer>();
  57.   db.DropTable<Product>();
  58.   db.DropTable<Employee>();
  59.  
  60.   db.CreateTable<Employee>();
  61.   db.CreateTable<Product>();
  62.   db.CreateTable<Customer>();
  63.   db.CreateTable<Order>();
  64.   db.CreateTable<OrderDetail>();
  65.  
  66.   db.Insert(new Employee { Id = 1, Name = "Employee 1" });
  67.   db.Insert(new Employee { Id = 2, Name = "Employee 2" });
  68.   var product1 = new Product { Id = 1, Name = "Product 1", UnitPrice = 10 };
  69.   var product2 = new Product { Id = 2, Name = "Product 2", UnitPrice = 20 };
  70.   db.Save(product1, product2);
  71.  
  72.   var customer = new Customer {
  73.       FirstName = "Orm",
  74.       LastName = "Lite",
  75.       Email = "ormlite@servicestack.net",
  76.       PhoneNumbers =
  77.       {
  78.           { PhoneType.Home, "555-1234" },
  79.           { PhoneType.Work, "1-800-1234" },
  80.           { PhoneType.Mobile, "818-123-4567" },
  81.       },
  82.       Addresses =
  83.       {
  84.           { AddressType.Work, new Address { 
  85.             Line1 = "1 Street", Country = "US", State = "NY", City = "New York", ZipCode = "10101" } 
  86.           },
  87.       },
  88.       CreatedAt = DateTime.UtcNow,
  89.   };
  90.  
  91.   var customerId = db.Insert(customer, selectIdentity: true); //Get Auto Inserted Id
  92.   customer = db.Single<Customer>(new { customer.Email }); //Query
  93.   Assert.That(customer.Id, Is.EqualTo(customerId));
  94.  
  95.   //Direct access to System.Data.Transactions:
  96.   using (IDbTransaction trans = db.OpenTransaction(IsolationLevel.ReadCommitted))
  97.   {
  98.       var order = new Order {
  99.           CustomerId = customer.Id,
  100.           EmployeeId = 1,
  101.           OrderDate = DateTime.UtcNow,
  102.           Freight = 10.50m,
  103.           ShippingAddress = new Address { 
  104.             Line1 = "3 Street", Country = "US", State = "NY", City = "New York", ZipCode = "12121" },
  105.       };
  106.       db.Save(order); //Inserts 1st time
  107.  
  108.       //order.Id populated on Save().
  109.  
  110.       var orderDetails = new[] {
  111.           new OrderDetail {
  112.               OrderId = order.Id,
  113.               ProductId = product1.Id,
  114.               Quantity = 2,
  115.               UnitPrice = product1.UnitPrice,
  116.           },
  117.           new OrderDetail {
  118.               OrderId = order.Id,
  119.               ProductId = product2.Id,
  120.               Quantity = 2,
  121.               UnitPrice = product2.UnitPrice,
  122.               Discount = .15m,
  123.           }
  124.       };
  125.  
  126.       db.Save(orderDetails);
  127.  
  128.       order.Total = orderDetails.Sum(x => x.UnitPrice * x.Quantity * x.Discount) + order.Freight;
  129.  
  130.       db.Save(order); //Updates 2nd Time
  131.  
  132.       trans.Commit();
  133.   }}

Running this against a SQL Server database will yield the results below:

SQL Server Management Studio results

Notice the POCO types are stored in the very fast and Versatile JSV Format which although hard to do - is actually more compact, human and parser-friendly than JSON :)

Ignoring DTO Properties

You may use the [Ignore] attribute to denote DTO properties that are not fields in the table. This will force the SQL generation to ignore that property.

More Examples

In its simplest useage, OrmLite can persist any POCO type without any attributes required:

  1. public class SimpleExample{
  2.     public int Id { get; set; }
  3.     public string Name { get; set; }}//Set once before use (i.e. in a static constructor).OrmLiteConfig.DialectProvider = SqliteDialect.Provider;using (IDbConnection db = "/path/to/db.sqlite".OpenDbConnection()){
  4.     db.CreateTable<SimpleExample>(true);
  5.     db.Insert(new SimpleExample { Id=1, Name="Hello, World!"});
  6.     var rows = db.Select<SimpleExample>();
  7.  
  8.     Assert.That(rows, Has.Count(1));
  9.     Assert.That(rows[0].Id, Is.EqualTo(1));}

To get a better idea of the features of OrmLite lets walk through a complete example using sample tables from the Northwind database. _ (Full source code for this example is available here.) _

So with no other configuration using only the classes below:

  1. [Alias("Shippers")]public class Shipper
  2.     : IHasId<int>{    [AutoIncrement]    [Alias("ShipperID")]
  3.     public int Id { get; set; }    [Required]    [Index(Unique = true)]    [StringLength(40)]
  4.     public string CompanyName { get; set; }    [StringLength(24)]
  5.     public string Phone { get; set; }    [References(typeof(ShipperType))]
  6.     public int ShipperTypeId { get; set; }}[Alias("ShipperTypes")]public class ShipperType
  7.     : IHasId<int>{    [AutoIncrement]    [Alias("ShipperTypeID")]
  8.     public int Id { get; set; }    [Required]    [Index(Unique = true)]    [StringLength(40)]
  9.     public string Name { get; set; }}public class SubsetOfShipper{
  10.     public int ShipperId { get; set; }
  11.     public string CompanyName { get; set; }}public class ShipperTypeCount{
  12.     public int ShipperTypeId { get; set; }
  13.     public int Total { get; set; }}

Creating tables

Creating tables is a simple 1-liner:

  1. using (IDbConnection db = ":memory:".OpenDbConnection()){
  2.     db.CreateTable<ShipperType>();
  3.     db.CreateTable<Shipper>();}/* In debug mode the line above prints:DEBUG: CREATE TABLE "ShipperTypes" (  "ShipperTypeID" INTEGER PRIMARY KEY AUTOINCREMENT,   "Name" VARCHAR(40) NOT NULL );DEBUG: CREATE UNIQUE INDEX uidx_shippertypes_name ON "ShipperTypes" ("Name" ASC);DEBUG: CREATE TABLE "Shippers" (  "ShipperID" INTEGER PRIMARY KEY AUTOINCREMENT,   "CompanyName" VARCHAR(40) NOT NULL,   "Phone" VARCHAR(24) NULL,   "ShipperTypeId" INTEGER NOT NULL,   CONSTRAINT "FK_Shippers_ShipperTypes" FOREIGN KEY ("ShipperTypeId") REFERENCES "ShipperTypes" ("ShipperID") );DEBUG: CREATE UNIQUE INDEX uidx_shippers_companyname ON "Shippers" ("CompanyName" ASC);*/

Transaction Support

As we have direct access to IDbCommand and friends - playing with transactions is easy:

  1.   var trainsType = new ShipperType { Name = "Trains" };
  2.   var planesType = new ShipperType { Name = "Planes" };
  3.  
  4.   //Playing with transactions
  5.   using (IDbTransaction dbTrans = db.OpenTransaction())
  6.   {
  7.       db.Save(trainsType);
  8.       db.Save(planesType);
  9.  
  10.       dbTrans.Commit();
  11.   }
  12.  
  13.   using (IDbTransaction dbTrans = db.OpenTransaction(IsolationLevel.ReadCommitted))
  14.   {
  15.       db.Insert(new ShipperType { Name = "Automobiles" });
  16.       Assert.That(db.Select<ShipperType>(), Has.Count.EqualTo(3));
  17.   }
  18.     Assert.That(db.Select<ShipperType>(), Has.Count(2));

CRUD Operations

No ORM is complete without the standard crud operations:

  1.     //Performing standard Insert's and Selects
  2.   db.Insert(new Shipper { CompanyName = "Trains R Us", Phone = "555-TRAINS", ShipperTypeId = trainsType.Id });
  3.   db.Insert(new Shipper { CompanyName = "Planes R Us", Phone = "555-PLANES", ShipperTypeId = planesType.Id });
  4.   db.Insert(new Shipper { CompanyName = "We do everything!", Phone = "555-UNICORNS", ShipperTypeId = planesType.Id });
  5.  
  6.   var trainsAreUs = db.SingleFmt<Shipper>("ShipperTypeId = {0}", trainsType.Id);
  7.   Assert.That(trainsAreUs.CompanyName, Is.EqualTo("Trains R Us"));
  8.   Assert.That(db.SelectFmt<Shipper>("CompanyName = {0} OR Phone = {1}", "Trains R Us", "555-UNICORNS"), Has.Count.EqualTo(2));
  9.   Assert.That(db.SelectFmt<Shipper>("ShipperTypeId = {0}", planesType.Id), Has.Count.EqualTo(2));
  10.  
  11.   //Lets update a record
  12.   trainsAreUs.Phone = "666-TRAINS";
  13.   db.Update(trainsAreUs);
  14.           Assert.That(db.SingleById<Shipper>(trainsAreUs.Id).Phone, Is.EqualTo("666-TRAINS"));
  15.  
  16.   //Then make it dissappear
  17.   db.Delete(trainsAreUs);
  18.           Assert.That(db.SingleById<Shipper>(trainsAreUs.Id), Is.Null);
  19.  
  20.   //And bring it back again
  21.   db.Insert(trainsAreUs);

Performing custom queries

And with access to raw sql when you need it - the database is your oyster :)

  1.     var partialColumns = db.SelectFmt<SubsetOfShipper>(typeof (Shipper), "ShipperTypeId = {0}", planesType.Id);
  2.     Assert.That(partialColumns, Has.Count.EqualTo(2));
  3.  
  4.     //Select into another POCO class that matches sql
  5.     var rows = db.SelectFmt<ShipperTypeCount>(
  6.       "SELECT ShipperTypeId, COUNT(*) AS Total FROM Shippers GROUP BY ShipperTypeId ORDER BY COUNT(*)");
  7.  
  8.     Assert.That(rows, Has.Count.EqualTo(2));
  9.     Assert.That(rows[0].ShipperTypeId, Is.EqualTo(trainsType.Id));
  10.     Assert.That(rows[0].Total, Is.EqualTo(1));
  11.     Assert.That(rows[1].ShipperTypeId, Is.EqualTo(planesType.Id));
  12.     Assert.That(rows[1].Total, Is.EqualTo(2));
  13.  
  14.  
  15.     //And finally lets quickly clean up the mess we've made:
  16.     db.DeleteAll<Shipper>();
  17.     db.DeleteAll<ShipperType>();
  19.     Assert.That(db.Select<Shipper>(), Has.Count.EqualTo(0));
  20.     Assert.That(db.Select<ShipperType>(), Has.Count.EqualTo(0));

Limitations

For simplicity, and to be able to have the same POCO class persisted in db4o, memcached, redis or on the filesystem (i.e. providers included in ServiceStack), each model must have a single primary key, by convention OrmLite expects it to be Id although you use [Alias("DbFieldName")] attribute it map it to a column with a different name or use the [PrimaryKey] attribute to tell OrmLite to use a different property for the primary key.

You can still SELECT from these tables, you will just be unable to make use of APIs that rely on it, e.g.Update or Delete where the filter is implied (i.e. not specified), all the APIs that end with ById, etc.

Workaround single Primary Key limitation

A potential workaround to support tables with multiple primary keys is to create an auto generated Idproperty that returns a unique value based on all the primary key fields, e.g:

  1. public class OrderDetail{
  2.   public string Id { get { return this.OrderId + "/" + this.ProductId; } }
  3.  
  4.   public int OrderId { get; set; }
  5.   public int ProductId { get; set; }
  6.   public decimal UnitPrice { get; set; }
  7.   public short Quantity { get; set; }
  8.   public double Discount { get; set; }}

Oracle Provider Notes

The Oracle provider requires an installation of Oracle's ODP.NET. It has been tested with Oracle 11g but should work with 10g and perhaps even older versions. It has not been tested with Oracle 12c and does not support any new 12c features such as AutoIncrement keys. It also does not support the new Oracle fully-managed client.

By default the Oracle provider stores Guids in the database as character strings and when generating SQL it quotes only table and column names that are reserved words in Oracle. That requires that you use the same quoting if you code your own SQL. Both of these options can be overridden, but overriding them will cause problems: the provider can store Guids as raw(16) but it cannot read them.

The Oracle provider uses Oracle sequences to implement AutoIncrement columns and it queries the sequence to get a new value in a separate database call. You can override the automatically generated sequence name with a

[Sequence("name")]

attribute on a field. The Sequence attribute implies [AutoIncrement], but you can use both on the same field.

Since Oracle has a very restrictive 30 character limit on names, it is strongly suggested that you use short entity class and field names or aliases, remembering that indexes and foreign keys get compound names. If you use long names, the provider will squash them to make them compliant with the restriction. The algorithm used is to remove all vowels ("aeiouy") and if still too long then every fourth letter starting with the third one and finally if still too long to truncate the name. You must apply the same squashing algorithm if you are coding your own SQL.

The previous version of ServiceStack.OrmLite.Oracle used System.Data.OracleClient to talk to the database. Microsoft has deprecated that client, but it does still mostly work if you construct the Oracle provider like this:

  1. OracleOrmLiteDialectProvider.Instance = new OracleOrmLiteDialectProvider(
  2. compactGuid: false,
  3. quoteNames: false,
  4. clientProvider: OracleOrmLiteDialectProvider.MicrosoftProvider);

DateTimeOffset fields and, in locales that use a comma to separate the fractional part of a floating point number, some aspects of using floating point numbers, do not work with System.Data.OracleClient.

Community Resources

Other notable Micro ORMs for .NET

Many performance problems can be mitigated and a lot of use-cases can be simplified without the use of a heavyweight ORM, and their config, mappings and infrastructure. As performance is the most important feature we can recommend the following list, each with their own unique special blend of features.

  • Dapper - by @samsaffron and @marcgravell

    • The current performance king, supports both POCO and dynamic access, fits in a single class. Put in production to solve StackOverflow's DB Perf issues. Requires .NET 4.

  • PetaPoco - by @toptensoftware

    • Fast, supports dynamics, expandos and typed POCOs, fits in a single class, runs on .NET 3.5 and Mono. Includes optional T4 templates for POCO table generation.

  • Massive - by @robconery

    • Fast, supports dynamics and expandos, smart use of optional params to provide a wrist-friendly api, fits in a single class. Multiple RDBMS support. Requires .NET 4.

  • Simple.Data - by @markrendle

    • A little slower than above ORMS, most wrist-friendly courtesy of a dynamic API, multiple RDBMS support inc. Mongo DB. Requires .NET 4.

转载于:https://my.oschina.net/bv10000/blog/313015

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号