added siaqodb

NzbDrone.Core/Datastore/SiaqodbProxy.cs

@@ -0,0 +1,87 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Sqo;
+
+namespace NzbDrone.Core.Datastore
+{
+    public interface IObjectDatabase : IDisposable
+    {
+        IEnumerable<T> AsQueryable<T>();
+        T Insert<T>(T obj) where T : BaseRepositoryModel;
+        T Update<T>(T obj) where T : BaseRepositoryModel;
+        IList<T> InsertMany<T>(IList<T> objects) where T : BaseRepositoryModel;
+        IList<T> UpdateMany<T>(IList<T> objects) where T : BaseRepositoryModel;
+        void Delete<T>(T obj) where T : BaseRepositoryModel;
+        void DeleteMany<T>(IEnumerable<T> objects) where T : BaseRepositoryModel;
+    }
+
+    public class SiaqodbProxy : IObjectDatabase
+    {
+        private readonly Siaqodb _db;
+
+        public SiaqodbProxy(Siaqodb db)
+        {
+            _db = db;
+        }
+
+        public void Dispose()
+        {
+
+        }
+
+        public IEnumerable<T> AsQueryable<T>()
+        {
+            return _db.Cast<T>();
+        }
+
+        public T Insert<T>(T obj) where T : BaseRepositoryModel
+        {
+            if (obj.OID != 0)
+            {
+                throw new InvalidOperationException("Attempted to insert object with existing ID as new object");
+            }
+
+             _db.StoreObject(obj);
+            return obj;
+        }
+
+        public T Update<T>(T obj) where T : BaseRepositoryModel
+        {
+            if (obj.OID == 0)
+            {
+                throw new InvalidOperationException("Attempted to update object without an ID");
+            }
+
+            _db.StoreObject(obj);
+            return obj;
+        }
+
+        public IList<T> InsertMany<T>(IList<T> objects) where T : BaseRepositoryModel
+        {
+            return DoMany(objects,Insert);
+        }
+
+        public IList<T> UpdateMany<T>(IList<T> objects) where T : BaseRepositoryModel
+        {
+            return DoMany(objects, Update);
+
+        }
+
+        public void Delete<T>(T obj) where T : BaseRepositoryModel
+        {
+            throw new NotImplementedException();
+        }
+
+        public void DeleteMany<T>(IEnumerable<T> objects) where T : BaseRepositoryModel
+        {
+            throw new NotImplementedException();
+        }
+
+        private IList<T> DoMany<T>(IEnumerable<T> objects, Func<T, T> function) where T : BaseRepositoryModel
+        {
+            return objects.Select(function).ToList();
+        }
+
+    }
+}