Webiant Logo Webiant Logo
☌

  1. No results found.

    Try your search with a different keyword or use * as a wildcard.

NopDataProviderTests.cs

using System.Text;
using FluentAssertions;
using Nop.Core;
using Nop.Core.Domain.Catalog;
using Nop.Core.Domain.Gdpr;
using Nop.Data;
using Nop.Web.Models.Install;
using NUnit.Framework;

namespace Nop.Tests.Nop.Data.Tests;

[TestFixture]
public class NopDataProviderTests : BaseNopTest
{
    [TearDown]
    public async Task TearDown()
    {
        try
        {
            var dataProvider = GetService();
            await dataProvider.TruncateAsync(true);
        }
        catch
        {
            //ignore 
        }

        SetDataProviderType(DataProviderType.Unknown);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public void CanCreateForeignKeyName(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var foreignTable = "foreignTable";
        var foreignColumn = "foreignColumn";
        var primaryTable = "primaryTable";
        var primaryColumn = "primaryColumn";

        var foreignKeyName =
            dataProvider.CreateForeignKeyName(foreignTable, foreignColumn, primaryTable, primaryColumn);

        switch (type)
        {

            case DataProviderType.SqlServer:
            case DataProviderType.PostgreSQL:
                foreignKeyName.Should()
                    .Be($"FK_{foreignTable}_{foreignColumn}_{primaryTable}_{primaryColumn}");
                break;

            case DataProviderType.MySql:
            case DataProviderType.Unknown:
                foreignKeyName.Should()
                    .Be("FK_" + HashHelper.CreateHash(Encoding.UTF8.GetBytes($"{foreignTable}_{foreignColumn}_{primaryTable}_{primaryColumn}"), "SHA1"));
                break;
        }
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public void CanGetIndexName(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var targetTable = "targetTable";
        var targetColumn = "targetColumn";

        var indexName = dataProvider.GetIndexName(targetTable, targetColumn);

        switch (type)
        {

            case DataProviderType.SqlServer:
            case DataProviderType.PostgreSQL:
                indexName.Should()
                    .Be($"IX_{targetTable}_{targetColumn}");
                break;

            case DataProviderType.MySql:
            case DataProviderType.Unknown:
                indexName.Should()
                    .Be("IX_" + HashHelper.CreateHash(Encoding.UTF8.GetBytes($"{targetTable}_{targetColumn}"), "SHA1"));
                break;
        }
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanCreateTempDataStorage(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();
        var productRepository = GetService>();

        var tableName = "TestTempDataTable".ToLower();

        await using var data = await dataProvider.CreateTempDataStorageAsync(tableName,
            productRepository.Table.Select(p => new { p.Name, p.Id, p.Deleted }));

        data.Count().Should().Be(productRepository.GetAll(query => query).Count);

        var rez = await dataProvider.QueryAsync($"select * from {tableName}");

        rez.Count.Should().Be(data.Count());
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanInsertEntity(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        await dataProvider.InsertEntityAsync(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.TruncateAsync();
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanUpdateEntity(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        await dataProvider.UpdateEntityAsync(new GdprConsent
        {
            Id = gdprConsent.Id,
            Message = "Updated test tax category"
        });
        var updatedGdprConsent = dataProvider.GetTable().FirstOrDefault(tc => tc.Id == gdprConsent.Id);
        await dataProvider.TruncateAsync();

        gdprConsent.Id.Should().BeGreaterThan(0);
        updatedGdprConsent?.Message.Should().NotBeEquivalentTo(gdprConsent.Message);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanUpdateEntities(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        await dataProvider.UpdateEntitiesAsync(new[]
        {
            new GdprConsent
            {
                Id = gdprConsent.Id,
                Message = "Updated test tax category"
            }
        });
        var updatedGdprConsent = dataProvider.GetTable().FirstOrDefault(tc => tc.Id == gdprConsent.Id);
        await dataProvider.TruncateAsync();

        gdprConsent.Id.Should().BeGreaterThan(0);
        updatedGdprConsent?.Message.Should().NotBeEquivalentTo(gdprConsent.Message);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanDeleteEntity(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.DeleteEntityAsync(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(0);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanBulkDeleteEntities(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.BulkDeleteEntitiesAsync(new List { gdprConsent });
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.BulkDeleteEntitiesAsync(_ => true);
        dataProvider.GetTable().Count().Should().Be(0);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanBulkInsertEntities(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };

        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        await dataProvider.BulkInsertEntitiesAsync(new[] { gdprConsent });
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.TruncateAsync();
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanGetTable(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
        dataProvider.InsertEntity(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.DeleteEntityAsync(gdprConsent);
        dataProvider.GetTable().Count().Should().Be(0);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanGetTableIdentAsync(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var gdprConsent = new GdprConsent { DisplayOrder = 10, Message = "Test message 1" };
        await dataProvider.TruncateAsync(true);
        dataProvider.GetTable().Count().Should().Be(0);
        var nextId = await dataProvider.GetTableIdentAsync();

        nextId.Should().Be(type == DataProviderType.Unknown ? 0 : 1);

        dataProvider.InsertEntity(gdprConsent);

        nextId = await dataProvider.GetTableIdentAsync();
        if (type == DataProviderType.SqlServer || type == DataProviderType.Unknown)
            nextId.Should().Be(1);
        else
            nextId.Should().Be(2);

        dataProvider.InsertEntity(gdprConsent);

        nextId = await dataProvider.GetTableIdentAsync();

        if (type == DataProviderType.SqlServer || type == DataProviderType.Unknown)
            nextId.Should().Be(2);
        else
            nextId.Should().Be(3);

        await dataProvider.TruncateAsync(true);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public void CanBuildConnectionString(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        var connStr = dataProvider.BuildConnectionString(new InstallModel
        {
            DatabaseName = "test_db",
            ServerName = "127.0.0.1",
            IntegratedSecurity = false,
            Username = "test",
            Password = "passwd"
        });

        switch (type)
        {
            case DataProviderType.Unknown:
                connStr.Should()
                    .Be(@$"Data Source={CommonHelper.DefaultFileProvider.MapPath($"~/App_Data/")}test_db.sqlite;Mode=ReadWrite;Cache=Shared;Password=passwd");
                break;
            case DataProviderType.SqlServer:
                connStr.Should()
                    .Be(@"Data Source=127.0.0.1;Initial Catalog=test_db;Integrated Security=False;Persist Security Info=False;User ID=test;Password=passwd;Trust Server Certificate=True");
                break;
            case DataProviderType.MySql:
                connStr.Should()
                    .Be(@"Server=127.0.0.1;User ID=test;Password=passwd;Database=test_db;Allow User Variables=True");
                break;
            case DataProviderType.PostgreSQL:
                connStr.Should()
                    .Be(@"Host=127.0.0.1;Database=test_db;Username=test;Password=passwd");
                break;
        }

        Assert.Throws(() => dataProvider.BuildConnectionString(null));

        if (type == DataProviderType.SqlServer)
            return;

        Assert.Throws(() => dataProvider.BuildConnectionString(new InstallModel()
        {
            IntegratedSecurity = true
        }));
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanSetTableIdent(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        await dataProvider.TruncateAsync(true);
        dataProvider.GetTable().Count().Should().Be(0);
        var nextId = await dataProvider.GetTableIdentAsync();

        nextId.Should().Be(type == DataProviderType.Unknown ? 0 : 1);

        await dataProvider.SetTableIdentAsync(10);
        nextId = await dataProvider.GetTableIdentAsync();

        nextId.Should().Be(10);
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanExecuteNonQuery(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        if (type != DataProviderType.PostgreSQL)
        {
            var rez = await dataProvider.ExecuteNonQueryAsync("select * from Product");
            rez.Should().Be(-1);

            rez = await dataProvider.ExecuteNonQueryAsync(
                "insert into GdprConsent(Message, IsRequired, RequiredMessage, DisplayDuringRegistration, DisplayOnCustomerInfoPage, DisplayOrder) values('test value', 0,'',0,0,1)");
            rez.Should().Be(1);

            rez = await dataProvider.ExecuteNonQueryAsync("delete from GdprConsent where Id=0");
            rez.Should().Be(0);
        }
        else
        {
            var rez = await dataProvider.ExecuteNonQueryAsync("select * from \"Product\"");
            rez.Should().Be(-1);

            rez = await dataProvider.ExecuteNonQueryAsync(
                "insert into \"GdprConsent\"(\"Message\", \"IsRequired\", \"RequiredMessage\", \"DisplayDuringRegistration\", \"DisplayOnCustomerInfoPage\", \"DisplayOrder\") values('test value', false,'',false,false,1)");
            rez.Should().Be(1);

            rez = await dataProvider.ExecuteNonQueryAsync("delete from \"GdprConsent\" where \"Id\"=0");
            rez.Should().Be(0);
        }

        await dataProvider.TruncateAsync();
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanQuery(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        if (type != DataProviderType.PostgreSQL)
        {
            var rez = await dataProvider.QueryAsync("select * from Product");
            rez.Count.Should().BeGreaterThan(40);
        }
        else
        {
            var rez = await dataProvider.QueryAsync("select * from \"Product\"");
            rez.Count.Should().BeGreaterThan(40);
        }
    }

    [Test]
    [TestCase(DataProviderType.Unknown)]
    [TestCase(DataProviderType.SqlServer)]
    [TestCase(DataProviderType.MySql)]
    [TestCase(DataProviderType.PostgreSQL)]
    public async Task CanTruncate(DataProviderType type)
    {
        if (!SetDataProviderType(type))
            return;

        var dataProvider = GetService();

        await dataProvider.TruncateAsync();
        dataProvider.InsertEntity(new GdprConsent { DisplayOrder = 10, Message = "Test message 1" });
        dataProvider.GetTable().Count().Should().Be(1);
        await dataProvider.TruncateAsync();
        dataProvider.GetTable().Count().Should().Be(0);
    }
}