Re-added old override GetColumns() & GetFromTables() so it can handle…

src/Dynamicweb.DataIntegration.Providers.UserProvider.csproj

@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
 	<PropertyGroup>
-		<Version>10.0.18</Version>
+		<Version>10.0.19</Version>
 		<AssemblyVersion>1.0.0.0</AssemblyVersion>
 		<Title>User Provider</Title>
 		<Description>User Provider</Description>

src/UserSourceReader.cs

@@ -4,6 +4,7 @@
 using System.Collections.Generic;
 using System.Data.SqlClient;
 using System.Globalization;
+using System.Linq;
 
 namespace Dynamicweb.DataIntegration.Providers.UserProvider;
 
@@ -160,11 +161,11 @@
                 conditionalsSql += " AND ";
             if (mapping.SourceTable.Name == "AccessUserGroup")
             {
                 conditionalsSql += string.Format("[AccessUser].[AccessUserType] NOT IN ({0})", string.Join(",", User.GetUserTypes(true)));
             }
             else
             {
                 conditionalsSql += string.Format("[AccessUser].[AccessUserType] IN ({0})", string.Join(",", User.GetUserTypes(true)));
             }
         }
         if (mapping.SourceTable.Name == "SystemFieldValue")
@@ -176,6 +177,49 @@
         return conditionalsSql;
     }
 
+    protected override string GetColumns()
+    {
+        string result = string.Empty;
+        if (mapping.SourceTable != null && (mapping.SourceTable.Name == "AccessUserGroup" || mapping.SourceTable.Name == "AccessUserAddress"))
+        {
+            if (mapping.SourceTable.Name == "AccessUserGroup")
+            {
+                result = mapping.GetColumnMappings().Aggregate("",
+                    (current, fm) => (fm.SourceColumn != null) ?
+                        current + "[" + UserProvider.GetOriginalColumnNameForGroups(fm.SourceColumn.Name) + "] AS [" + fm.SourceColumn.Name + "], " : current);
+            }
+            else
+            {
+                result = mapping.GetColumnMappings().Aggregate("", (current, fm) => (fm.SourceColumn != null) ?
+                    current + (fm.SourceColumn.Name == "AccessUserAddressUserID" ? "CAST([AccessUserAddressUserID] AS NVARCHAR) AS [AccessUserAddressUserID], " : "[" + fm.SourceColumn.Name + "], ")
+                    : current);
+            }
+            result = result.Substring(0, result.Length - 2);
+        }
+        else
+        {
+            return base.GetColumns();
+        }
+        return result;
+    }
+
+    protected override string GetFromTables()
+    {
+        string result = "[" + mapping.SourceTable.SqlSchema + "].[" + mapping.SourceTable.Name + "] ";
+        switch (mapping.SourceTable.Name)
+        {
+            case "AccessUserAddress":
+                result = result + " INNER JOIN [AccessUser] on [AccessUserAddress].[AccessUserAddressUserID] = [AccessUser].[AccessUserID]";
+                break;
+            case "AccessUserGroup":
+                result = "[" + mapping.SourceTable.SqlSchema + "].[AccessUser] ";
+                break;
+            default:
+                break;
+        }
+        return result;
+    }
+
     internal static void UpdateExportedDataInDb(SqlConnection connection)
     {
         if (_tableNameWhereSqlDictionary.Keys.Count > 0)