Skip to content

Commit

Permalink
Added better error handling for stored procedures. General logging fo…
Browse files Browse the repository at this point in the history
…rmatting improvements. Merge pull request #21
  • Loading branch information
sorengranfeldt committed Sep 24, 2022
1 parent c0066ca commit 96ace33
Show file tree
Hide file tree
Showing 21 changed files with 1,392 additions and 1,435 deletions.
229 changes: 113 additions & 116 deletions Granfeldt.SQL.MA.UnitTests/Granfeldt.SQL.MA.UnitTests.cs
Original file line number Diff line number Diff line change
@@ -1,122 +1,119 @@
using System;
using Microsoft.MetadirectoryServices;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using Microsoft.MetadirectoryServices;
using System.Data;
using System.Data.SqlClient;

namespace Granfeldt
{
[TestClass]
public class SqlTests
{
SqlMethods methods = new SqlMethods();

[TestMethod]
public void GetObjectClasses()
{
methods.OpenConnection();
foreach (string str in methods.GetObjectClasses())
{
Tracer.TraceInformation("got-objectclass {0}", str);
}
methods.Dispose();
}

[TestMethod]
public void GetSingleValueColumns()
{
methods.OpenConnection();
foreach (AttributeDefinition ad in methods.GetSchema(Configuration.TableNameSingle))
{
}
methods.Dispose();
}

[TestMethod]
public void GetMultiValueColumns()
{
methods.OpenConnection();
foreach (AttributeDefinition ad in methods.GetSchema(Configuration.TableNameMulti))
{
}
methods.Dispose();
}

[TestMethod]
public void GetMASchema()
{

using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();
}
}

[TestMethod]
public void GetFullImport()
{
using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();

ma.Schema = schema;
ma.ImportType = OperationType.Full;

OpenImportConnectionRunStep dummyOpenImportRunStep = new OpenImportConnectionRunStep();

// fake runstep data
ma.ImportType = OperationType.Full;
ma.CustomData = "";
ma.PageSize = 100;

System.Collections.ObjectModel.KeyedCollection<string, ConfigParameter> configParams = null;
ma.OpenImportConnectionDetached(configParams, schema, null);

GetImportEntriesRunStep rs = new GetImportEntriesRunStep();

GetImportEntriesResults rest = new GetImportEntriesResults();
rest.MoreToImport = true;
while (rest.MoreToImport)
{
[TestClass]
public class SqlTests
{
SqlMethods methods = new SqlMethods();

[TestMethod]
public void GetObjectClasses()
{
methods.OpenConnection();
foreach (string str in methods.GetObjectClasses())
{
Tracer.TraceInformation("got-objectclass {0}", str);
}
methods.Dispose();
}

[TestMethod]
public void GetSingleValueColumns()
{
methods.OpenConnection();
foreach (AttributeDefinition ad in methods.GetSchema(Configuration.TableNameSingle))
{
}
methods.Dispose();
}

[TestMethod]
public void GetMultiValueColumns()
{
methods.OpenConnection();
foreach (AttributeDefinition ad in methods.GetSchema(Configuration.TableNameMulti))
{
}
methods.Dispose();
}

[TestMethod]
public void GetMASchema()
{

using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();
}
}

[TestMethod]
public void GetFullImport()
{
using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();

ma.Schema = schema;
ma.ImportType = OperationType.Full;

OpenImportConnectionRunStep dummyOpenImportRunStep = new OpenImportConnectionRunStep();

// fake runstep data
ma.ImportType = OperationType.Full;
ma.CustomData = "";
ma.PageSize = 100;

System.Collections.ObjectModel.KeyedCollection<string, ConfigParameter> configParams = null;
ma.OpenImportConnectionDetached(configParams, schema, null);

GetImportEntriesRunStep rs = new GetImportEntriesRunStep();

GetImportEntriesResults rest = new GetImportEntriesResults();
rest.MoreToImport = true;
while (rest.MoreToImport)
{
rest = ma.GetImportEntriesDetached(rs);
}
CloseImportConnectionRunStep dummyCloseImportRunStep = null;
ma.CloseImportConnectionDetached(dummyCloseImportRunStep);
}
}
[TestMethod]
public void GetDeltaImport()
{
using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();

// first get full data to get deltawatermark
ma.Schema = schema;
ma.ImportType = OperationType.Delta;
ma.CustomData = "140180";
ma.PageSize = 1;

System.Collections.ObjectModel.KeyedCollection<string, ConfigParameter> configParams = null;
ma.OpenImportConnectionDetached(configParams, schema, null);

GetImportEntriesRunStep rs = new GetImportEntriesRunStep();

GetImportEntriesResults rest = new GetImportEntriesResults();
rest.MoreToImport = true;
while (rest.MoreToImport)
{
rest = ma.GetImportEntriesDetached(rs);
}

CloseImportConnectionRunStep dummyCloseImportRunStep = null;
ma.CloseImportConnectionDetached(dummyCloseImportRunStep);
}
}

}
}

CloseImportConnectionRunStep dummyCloseImportRunStep = null;
ma.CloseImportConnectionDetached(dummyCloseImportRunStep);
}
}
[TestMethod]
public void GetDeltaImport()
{
using (SQLManagementAgent ma = new SQLManagementAgent())
{
Configuration.Schema = ma.DefaultSchemaXml.XmlDeserializeFromString<SchemaConfiguration>();
Schema schema = ma.GetSchemaDetached();

// first get full data to get deltawatermark
ma.Schema = schema;
ma.ImportType = OperationType.Delta;
ma.CustomData = "140180";
ma.PageSize = 1;

System.Collections.ObjectModel.KeyedCollection<string, ConfigParameter> configParams = null;
ma.OpenImportConnectionDetached(configParams, schema, null);

GetImportEntriesRunStep rs = new GetImportEntriesRunStep();

GetImportEntriesResults rest = new GetImportEntriesResults();
rest.MoreToImport = true;
while (rest.MoreToImport)
{
rest = ma.GetImportEntriesDetached(rs);
}

CloseImportConnectionRunStep dummyCloseImportRunStep = null;
ma.CloseImportConnectionDetached(dummyCloseImportRunStep);
}
}

}
}
1 change: 0 additions & 1 deletion Granfeldt.SQL.MA.UnitTests/Properties/AssemblyInfo.cs
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;

// General Information about an assembly is controlled through the following
Expand Down
Loading

0 comments on commit 96ace33

Please sign in to comment.