Creates a wrapper around the offical OrientDB API with create, update, delete and get

kostkams · kostkams · commit d2a3607a0c2d · 2019-01-19T03:53:12.000+01:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,3 @@
+**/.vs/
+**/bin/
+**/obj/
diff --git a/3rd Party/OrientDB/OrientDB-Net.binary.Innov8tive.dll b/3rd Party/OrientDB/OrientDB-Net.binary.Innov8tive.dll
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Console/CompanyBO.cs b/Source/OrientDB.Net.Core.BusinessObjects.Console/CompanyBO.cs
@@ -0,0 +1,22 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects.Console
+{
+    public class CompanyBO : BusinessObject, ICompanyBO
+    {
+        public CompanyBO()
+        {
+            ClassName = "Company";
+        }
+
+        [DocumentProperty("CompanyName", true)]
+        public string Name { get; set; }
+    }
+
+    public static class CompanyBOExtension{
+        public static ICompanyBO CreateCompany(this ITransaction transaction)
+        {
+            var company = new CompanyBO();
+            transaction.Create(company);
+            return company;
+        }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Console/ICompanyBO.cs b/Source/OrientDB.Net.Core.BusinessObjects.Console/ICompanyBO.cs
@@ -0,0 +1,8 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects.Console
+{
+    public interface ICompanyBO : IBusinessObject
+    {
+        string Name { get; set; }
+        
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Console/OrientDB.Net.Core.BusinessObjects.Console.csproj b/Source/OrientDB.Net.Core.BusinessObjects.Console/OrientDB.Net.Core.BusinessObjects.Console.csproj
@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp3.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\OrientDB.Net.Core.BusinessObjects\OrientDB.Net.Core.BusinessObjects.csproj" />
+  </ItemGroup>
+
+</Project>
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Console/Program.cs b/Source/OrientDB.Net.Core.BusinessObjects.Console/Program.cs
@@ -0,0 +1,37 @@
+﻿using System.Linq;
+
+namespace OrientDB.Net.Core.BusinessObjects.Console
+{
+    internal class Program
+    {
+        private static void Main(string[] args)
+        {
+            var businessDocument = BusinessDocumentFactory.Connect(new ConnectionInfo("localhost",
+                                                                                      2424,
+                                                                                      "root",
+                                                                                      "rootpwd",
+                                                                                      "Helios",
+                                                                                      EDatabaseType.Graph));
+
+            using (var session = businessDocument.OpenSession())
+            {
+                var company = session.Get<ICompanyBO>(e => "Test" == e.Name && (e.Name != "tu" || e.Name != "tsssu") /**/);
+                var transaction = session.BeginTransaction();
+                var comp = transaction.CreateCompany();
+                comp.Name = "Neu";
+                transaction.Commit();
+                var company1 = session.Get<ICompanyBO>();
+                
+                transaction = session.BeginTransaction();
+                comp.Name = "Neu 1";
+                transaction.Update(comp);
+                transaction.Commit();
+
+                
+                transaction = session.BeginTransaction();
+                transaction.Delete(session.Get<ICompanyBO>(c => c.Name == "Neu 1").First());
+                transaction.Commit();
+            }
+        }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Generator/OrientDB.Net.Core.BusinessObjects.Generator.csproj b/Source/OrientDB.Net.Core.BusinessObjects.Generator/OrientDB.Net.Core.BusinessObjects.Generator.csproj
@@ -0,0 +1,8 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp3.0</TargetFramework>
+  </PropertyGroup>
+
+</Project>
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.Generator/Program.cs b/Source/OrientDB.Net.Core.BusinessObjects.Generator/Program.cs
@@ -0,0 +1,12 @@
+﻿using System;
+
+namespace OrientDB.Net.Core.BusinessObjects.Generator
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            Console.WriteLine("Hello World!");
+        }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects.sln b/Source/OrientDB.Net.Core.BusinessObjects.sln
@@ -0,0 +1,37 @@
+﻿
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.28407.52
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "OrientDB.Net.Core.BusinessObjects", "OrientDB.Net.Core.BusinessObjects\OrientDB.Net.Core.BusinessObjects.csproj", "{1C5F1464-A7D9-4EA1-8DD0-ECD4E6DFBDDD}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "OrientDB.Net.Core.BusinessObjects.Generator", "OrientDB.Net.Core.BusinessObjects.Generator\OrientDB.Net.Core.BusinessObjects.Generator.csproj", "{2286C7C9-D2DC-446B-8FBE-509E18D6B7A2}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "OrientDB.Net.Core.BusinessObjects.Console", "OrientDB.Net.Core.BusinessObjects.Console\OrientDB.Net.Core.BusinessObjects.Console.csproj", "{421E5BC0-3AD8-4E87-B4A5-C95B063DB816}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{1C5F1464-A7D9-4EA1-8DD0-ECD4E6DFBDDD}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{1C5F1464-A7D9-4EA1-8DD0-ECD4E6DFBDDD}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{1C5F1464-A7D9-4EA1-8DD0-ECD4E6DFBDDD}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{1C5F1464-A7D9-4EA1-8DD0-ECD4E6DFBDDD}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2286C7C9-D2DC-446B-8FBE-509E18D6B7A2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2286C7C9-D2DC-446B-8FBE-509E18D6B7A2}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2286C7C9-D2DC-446B-8FBE-509E18D6B7A2}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2286C7C9-D2DC-446B-8FBE-509E18D6B7A2}.Release|Any CPU.Build.0 = Release|Any CPU
+		{421E5BC0-3AD8-4E87-B4A5-C95B063DB816}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{421E5BC0-3AD8-4E87-B4A5-C95B063DB816}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{421E5BC0-3AD8-4E87-B4A5-C95B063DB816}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{421E5BC0-3AD8-4E87-B4A5-C95B063DB816}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {523754E0-89A2-474A-BB73-5493CE009CF0}
+	EndGlobalSection
+EndGlobal
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/BusinessDocument.cs b/Source/OrientDB.Net.Core.BusinessObjects/BusinessDocument.cs
@@ -0,0 +1,26 @@
+﻿using System;
+using Orient.Client;
+
+namespace OrientDB.Net.Core.BusinessObjects
+{
+    public class BusinessDocument : IBusinessDocument
+    {
+        private readonly ConnectionInfo connectionInfo;
+
+        public BusinessDocument(ConnectionInfo connectionInfo)
+        {
+            this.connectionInfo = connectionInfo;
+        }
+
+        public string Server => connectionInfo.HostName;
+        public string DatabaseName => connectionInfo.DatabaseName;
+        public EDatabaseType DatabaseType => connectionInfo.DatabaseType;
+        public ISession OpenSession()
+        {
+            CurrentSession = new Session(connectionInfo);
+            return CurrentSession;
+        }
+
+        public ISession CurrentSession { get; private set; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/BusinessDocumentFactory.cs b/Source/OrientDB.Net.Core.BusinessObjects/BusinessDocumentFactory.cs
@@ -0,0 +1,11 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public static class BusinessDocumentFactory
+    {
+        public static IBusinessDocument Connect(ConnectionInfo connectionInfo)
+        {
+            var businessDocument = new BusinessDocument(connectionInfo);
+            return businessDocument;
+        }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/BusinessObject.cs b/Source/OrientDB.Net.Core.BusinessObjects/BusinessObject.cs
@@ -0,0 +1,9 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public abstract class BusinessObject : IBusinessObject
+    {
+        public string Id { get; internal set; }
+        public string ClassName { get; protected set; }
+        public int Version { get; internal set; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/ConnectionInfo.cs b/Source/OrientDB.Net.Core.BusinessObjects/ConnectionInfo.cs
@@ -0,0 +1,40 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public class ConnectionInfo
+    {
+        public ConnectionInfo(string hostName,
+                              int port,
+                              string userName,
+                              string password,
+                              string databaseName,
+                              EDatabaseType databaseType,
+                              string poolAlias)
+        {
+            HostName = hostName;
+            UserName = userName;
+            Password = password;
+            Port = port;
+            DatabaseName = databaseName;
+            DatabaseType = databaseType;
+            PoolAlias = poolAlias;
+        }
+
+        public ConnectionInfo(string hostName,
+                              int port,
+                              string userName,
+                              string password,
+                              string databaseName,
+                              EDatabaseType databaseType)
+            : this(hostName, port, userName, password, databaseName, databaseType, "Default")
+        {
+        }
+
+        public string HostName { get; }
+        public string UserName { get; }
+        public string Password { get; }
+        public int Port { get; }
+        public string DatabaseName { get; }
+        public EDatabaseType DatabaseType { get; }
+        public string PoolAlias { get; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/DocumentPropertyAttribute.cs b/Source/OrientDB.Net.Core.BusinessObjects/DocumentPropertyAttribute.cs
@@ -0,0 +1,22 @@
+﻿using System;
+
+namespace OrientDB.Net.Core.BusinessObjects
+{
+    [AttributeUsage(AttributeTargets.Property)]
+    public class DocumentPropertyAttribute : Attribute
+    {
+        public DocumentPropertyAttribute(string key, bool required)
+        {
+            Key = key;
+            Required = required;
+        }
+
+        public DocumentPropertyAttribute(string key)
+            : this(key, false)
+        {
+        }
+
+        public string Key { get; set; }
+        public bool Required { get; set; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/EDatabaseType.cs b/Source/OrientDB.Net.Core.BusinessObjects/EDatabaseType.cs
@@ -0,0 +1,8 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public enum EDatabaseType
+    {
+        Document = 0,
+        Graph = 1
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/IBusinessDocument.cs b/Source/OrientDB.Net.Core.BusinessObjects/IBusinessDocument.cs
@@ -0,0 +1,13 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public interface IBusinessDocument
+    {
+        string Server { get; }
+        string DatabaseName { get; }
+        EDatabaseType DatabaseType { get; }
+
+        ISession OpenSession();
+
+        ISession CurrentSession { get; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/IBusinessObject.cs b/Source/OrientDB.Net.Core.BusinessObjects/IBusinessObject.cs
@@ -0,0 +1,11 @@
+﻿namespace OrientDB.Net.Core.BusinessObjects
+{
+    public interface IBusinessObject
+    {
+        string Id { get; }
+
+        string ClassName { get; }
+
+        int Version { get; }
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/ISession.cs b/Source/OrientDB.Net.Core.BusinessObjects/ISession.cs
@@ -0,0 +1,14 @@
+﻿using System;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+
+namespace OrientDB.Net.Core.BusinessObjects
+{
+    public interface ISession : IDisposable
+    {
+        IReadOnlyList<TBO> Get<TBO>(Expression<Func<TBO, bool>> query) where TBO : IBusinessObject;
+        IReadOnlyList<TBO> Get<TBO>() where TBO : IBusinessObject;
+
+        ITransaction BeginTransaction();
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/ITransaction.cs b/Source/OrientDB.Net.Core.BusinessObjects/ITransaction.cs
@@ -0,0 +1,17 @@
+﻿using System;
+
+namespace OrientDB.Net.Core.BusinessObjects
+{
+    public interface ITransaction
+    {
+        event EventHandler<bool> Commited; 
+        void Commit();
+        void Reset();
+
+        void Create<TBO>(TBO businessObject) where TBO : IBusinessObject;
+
+        void Delete(IBusinessObject businessObject);
+
+        void Update(IBusinessObject businessObject);
+    }
+}
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/OrientDB.Net.Core.BusinessObjects.csproj b/Source/OrientDB.Net.Core.BusinessObjects/OrientDB.Net.Core.BusinessObjects.csproj
@@ -0,0 +1,14 @@
+﻿<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+    <SuppressNETCoreSdkPreviewMessage>true</SuppressNETCoreSdkPreviewMessage>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Reference Include="OrientDB-Net.binary.Innov8tive">
+      <HintPath>..\..\3rd Party\OrientDB\OrientDB-Net.binary.Innov8tive.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+
+</Project>
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/Query/GetQuery.cs b/Source/OrientDB.Net.Core.BusinessObjects/Query/GetQuery.cs
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/Session.cs b/Source/OrientDB.Net.Core.BusinessObjects/Session.cs
diff --git a/Source/OrientDB.Net.Core.BusinessObjects/Transaction.cs b/Source/OrientDB.Net.Core.BusinessObjects/Transaction.cs
