Implemented Test containers for integration testing - phase 1

Ginger/GingerCoreNET/GingerCoreNET.csproj

@@ -292,7 +292,7 @@
     <PackageReference Include="MySql.Data" Version="8.0.16" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="Npgsql" Version="4.0.7" />
-    <PackageReference Include="NPOI" Version="2.5.3" />
+    <PackageReference Include="NPOI" Version="2.6.2" />
     <PackageReference Include="NUglify" Version="1.9.7" />
     <PackageReference Include="protobuf-net" Version="3.2.26" />
     <PackageReference Include="protobuf-net.Core" Version="3.2.26" />

Ginger/GingerCoreNETUnitTest/DatabaseTest/CouchbaseIntegrationTests.cs

@@ -0,0 +1,126 @@
+using Couchbase;
+using Couchbase.Configuration.Client;
+using GingerCore.Actions;
+using GingerCore.Environments;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Testcontainers.Couchbase;
+
+namespace GingerCoreNETUnitTest.DatabaseTest
+{
+    [TestClass]
+    public sealed class CouchbaseIntegrationTests
+    {
+
+        private static readonly CouchbaseContainer _couchbaseContainer = new CouchbaseBuilder().Build();
+
+        [ClassInitialize]
+        public static async Task ClassInitialize(TestContext context)
+        {
+            await _couchbaseContainer.StartAsync();
+            await CreateTestData();
+
+        }
+
+        [TestCleanup]
+        public Task DisposeAsync()
+        {
+            return _couchbaseContainer.DisposeAsync().AsTask();
+        }
+        public static async Task CreateTestData()
+        {
+
+            try
+            {
+                //      var clusterOptions = new ClusterOptions();
+                //      clusterOptions.ConnectionString = _couchbaseContainer.GetConnectionString();
+                //      clusterOptions.UserName = CouchbaseBuilder.DefaultUsername;
+                //      clusterOptions.Password = CouchbaseBuilder.DefaultPassword;
+
+                //      var cluster = await Cluster.ConnectAsync(clusterOptions)
+                //.ConfigureAwait(true);
+
+                //      // When
+                //      var ping = await cluster.PingAsync()
+                //          .ConfigureAwait(true);
+
+                //      var bucket = await cluster.BucketAsync(_couchbaseContainer.Buckets.Single().Name)
+                //          .ConfigureAwait(true);
+
+                // When
+                //var database = await client.Database.PutAsync()
+                //    .ConfigureAwait(true);
+                var cluster = new Cluster(new ClientConfiguration
+                {
+                    Servers = new List<Uri> { new Uri("http://" + _couchbaseContainer.GetConnectionString()) },
+                    UseSsl = false
+                });
+
+                cluster.Authenticate(CouchbaseBuilder.DefaultUsername, CouchbaseBuilder.DefaultPassword);
+
+                var clusterManager = cluster.CreateManager(CouchbaseBuilder.DefaultUsername, CouchbaseBuilder.DefaultPassword);
+                var buckets = clusterManager.ListBuckets().Value;
+                //var result = clusterManager.CreateBucket(new BucketSettings() { Name = "GingerBucket", BucketType = Couchbase.Core.Buckets.BucketTypeEnum.Couchbase, AuthType = Couchbase.Authentication.AuthType.None });
+                //var bucket = cluster.OpenBucket("GingerBucket");
+                var bucket  = cluster.OpenBucket(_couchbaseContainer.Buckets.FirstOrDefault().Name);
+                //// Insert sample data
+                var document = new Document<dynamic>
+                {
+                    Id = "Customer",
+                    Content = new[]{
+                    new { Name = "Mahesh", Value = 1 , Dept = "AQE I&T"},
+                    new { Name = "Jinendra", Value = 2, Dept = "AQE I&T"}
+                },
+                };
+                var upsertResult = await bucket.UpsertAsync(document);
+            }
+            catch (Exception ex)
+            {
+
+                throw;
+            }
+        }
+
+
+        [TestMethod]
+        public void ShouldReturnTwoCustomers()
+        {
+            // Given
+            Database db = new Database();
+            ActDBValidation mact = new ActDBValidation();
+            //actDBValidation
+
+            db.DBType = Database.eDBTypes.Couchbase;
+            DatabaseOperations databaseOperations = new DatabaseOperations(db);
+            db.DatabaseOperations = databaseOperations;
+            //ATT LS DB
+            //Db.DatabaseOperations.TNSCalculated
+            db.TNS = "http://" + _couchbaseContainer.GetConnectionString();
+            db.User = CouchbaseBuilder.DefaultUsername;
+            db.Pass = CouchbaseBuilder.DefaultPassword;
+            //  NoSqlBase noSqlBase = new GingerCouchbase(ActDBValidation.eDBValidationType.FreeSQL, db, mact);
+            mact.DB = db;
+
+            Boolean connectionSuccessful = mact.DB.DatabaseOperations.Connect();
+
+            // When
+            List<object> recs = new List<object>();
+            if (connectionSuccessful)
+            {
+                mact.SQL = "SELECT * FROM `Ginger-bucket` WHERE META().id = 1";
+                mact.Execute();
+
+                //db.DatabaseOperations.CloseConnection();
+            }
+
+            //then
+            Assert.AreEqual(connectionSuccessful, true, "Connected Successfully to CouchbaseDB");
+            //Assert.IsNotNull(recs.Count, 0);
+            Assert.AreEqual(recs.Count, 2, "Fetched 2 records from Postgre Table");
+        }
+
+    }
+}

Ginger/GingerCoreNETUnitTest/DatabaseTest/OracleIntegrationTests.cs

@@ -0,0 +1,90 @@
+using GingerCore.Environments;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Testcontainers.Oracle;
+using Oracle;
+using Oracle.ManagedDataAccess.Client;
+
+namespace GingerCoreNETUnitTest.DatabaseTest
+{
+    [TestClass]
+    public class OracleIntegrationTests
+    {
+        private static readonly OracleContainer _oracleContainer = new OracleBuilder().Build();
+
+        [ClassInitialize]
+        public static async Task ClassInitialize(TestContext context)
+        {
+            await _oracleContainer.StartAsync();
+            await CreateTestData();
+
+        }
+
+        [TestCleanup]
+        public Task DisposeAsync()
+        {
+            return _oracleContainer.DisposeAsync().AsTask();
+        }
+        public static async Task CreateTestData()
+        {
+            try
+            {
+                var scriptContent = "CREATE TABLE Customer (Id NUMBER PRIMARY KEY, Name varchar2(50));" +
+                                             "INSERT INTO Customer (Id, Name) VALUES (1, 'Mahesh'); " +
+                                             "INSERT INTO Customer (Id, Name) VALUES (2, 'kale');";
+                //var execResult = await _oracleContainer.ExecScriptAsync(scriptContent)
+        // .ConfigureAwait(false);
+
+                using (var connection = new OracleConnection(_oracleContainer.GetConnectionString()))
+                {
+                    await connection.OpenAsync();
+
+                    // Example: Create a table and insert test data
+                    using (var command = connection.CreateCommand())
+                    {
+                        command.CommandText = scriptContent;
+                        await command.ExecuteNonQueryAsync();
+                    }
+                }
+
+            }
+            catch (Exception ex)
+            {
+
+            }
+        }
+
+        [TestMethod]
+        public void ShouldReturnTwoCustomers()
+        {
+            // Given
+            Database db = new Database();
+            DatabaseOperations databaseOperations = new DatabaseOperations(db);
+            db.DatabaseOperations = databaseOperations;
+            db.DBType = Database.eDBTypes.Oracle;
+            //ATT LS DB            
+            db.ConnectionString = _oracleContainer.GetConnectionString();
+            Boolean connectionSuccessful = db.DatabaseOperations.Connect();
+
+
+            // When
+
+            List<object> recs = new List<object>();
+            if (connectionSuccessful)
+            {
+
+                string sqlQuery = "SELECT Id, Name FROM Customer";
+                recs = db.DatabaseOperations.FreeSQL(sqlQuery);
+
+                db.DatabaseOperations.CloseConnection();
+            }
+
+            //then
+            Assert.AreEqual(connectionSuccessful, true, "Connected Successfully to Oracle");
+            //Assert.IsNotNull(recs.Count, 0);
+            Assert.AreEqual(recs.Count, 2, "Fetched 2 records from Oracle Table");
+        }
+    }
+}

Ginger/GingerCoreNETUnitTest/DatabaseTest/PostgreSqlIntegrationTests.cs

@@ -0,0 +1,80 @@
+using GingerCore.Environments;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using Npgsql;
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Testcontainers.PostgreSql;
+
+namespace GingerCoreNETUnitTest.DatabaseTest
+{
+    [TestClass]
+    public sealed class PostgreSqlIntegrationTests
+    {
+        private static readonly PostgreSqlContainer _postgres = new PostgreSqlBuilder()
+            .WithImage("postgres:15-alpine")
+            .Build();
+
+        [ClassInitialize]
+        public static async Task ClassInitialize(TestContext context)
+        {
+            await _postgres.StartAsync();
+            await CreateTestData();
+
+        }
+
+        [TestCleanup]
+        public Task DisposeAsync()
+        {
+            return _postgres.DisposeAsync().AsTask();
+        }
+        public static async Task CreateTestData()
+        {
+            using (var connection = new NpgsqlConnection(_postgres.GetConnectionString()))
+            {
+                await connection.OpenAsync();
+
+                // Create test data
+                using (var command = connection.CreateCommand())
+                {
+                    command.CommandText = "CREATE TABLE Customer (Id serial PRIMARY KEY, Name varchar(255));" +
+                                          "INSERT INTO Customer (Name) VALUES ('1'), ('Mahesh kale');" +
+                                          "INSERT INTO Customer (Name) VALUES ('1'), ('Jinendra Ghodke');";
+                    await command.ExecuteNonQueryAsync();
+                }
+            }
+
+        }
+
+        [TestMethod]
+        public void ShouldReturnTwoCustomers()
+        {
+            // Given
+            Database db = new Database();
+            DatabaseOperations databaseOperations = new DatabaseOperations(db);
+            db.DatabaseOperations = databaseOperations;
+            db.DBType = Database.eDBTypes.PostgreSQL;
+            //ATT LS DB            
+            db.ConnectionString = _postgres.GetConnectionString();
+            Boolean connectionSuccessful = db.DatabaseOperations.Connect();
+
+
+            // When
+
+            List<object> recs = new List<object>();
+            if (connectionSuccessful)
+            {
+
+                string sqlQuery = "SELECT Id, Name FROM Customer";
+                recs = db.DatabaseOperations.FreeSQL(sqlQuery);
+
+                db.DatabaseOperations.CloseConnection();
+            }
+
+            //then
+            Assert.AreEqual(connectionSuccessful, true, "Connected Successfully to PostgreSQL");
+            //Assert.IsNotNull(recs.Count, 0);
+            Assert.AreEqual(recs.Count,2, "Fetched 2 records from Postgre Table");
+        }
+    }
+}

Ginger/GingerCoreNETUnitTest/GingerCoreNETUnitTest.csproj

@@ -85,7 +85,7 @@
     </Content>
   </ItemGroup>
 
-  <ItemGroup>
+  <ItemGroup>    
     <PackageReference Include="Ginger.ExecuterService.Contracts" Version="23.5.1" />
     <PackageReference Include="GingerTestHelper" Version="2.0.2" />
     <PackageReference Include="Microsoft.CodeAnalysis.Scripting" Version="3.7.0" />
@@ -94,6 +94,10 @@
     <PackageReference Include="MSTest.TestAdapter" Version="2.1.2" />
     <PackageReference Include="MSTest.TestFramework" Version="2.1.2" />
     <PackageReference Include="System.Resources.Extensions" Version="8.0.0" />
+    <PackageReference Include="Testcontainers" Version="3.7.0" />
+    <PackageReference Include="Testcontainers.Couchbase" Version="3.7.0" />
+    <PackageReference Include="Testcontainers.Oracle" Version="3.7.0" />
+    <PackageReference Include="Testcontainers.PostgreSql" Version="3.7.0" />
   </ItemGroup>
 
   <ItemGroup>

Ginger/GingerCoreNETUnitTest/RunTestslib/UnitTestRepositoryItemFactory.cs

@@ -9,6 +9,7 @@
 using GingerCore.Environments;
 using GingerCoreNET.ALMLib;
 using GingerCoreNET.SourceControl;
+using Oracle.ManagedDataAccess.Client;
 using System;
 using System.Collections.Generic;
 using System.Data.Common;
@@ -160,7 +161,7 @@ public IWebserviceDriverWindow GetWebserviceDriverWindow(BusinessFlow businessFl
 
         public DbConnection GetOracleConnection(string ConnectionString)
         {
-            throw new NotImplementedException();
+            return new OracleConnection(ConnectionString);
         }
 
         public bool IsSharedRepositoryItem(RepositoryItemBase item)