.editorconfig

@@ -7,9 +7,9 @@ root = true
 #### Core EditorConfig Options ####
 
 # Indentation and spacing
-indent_size = 3
+indent_size = 4
 indent_style = tab
-tab_width = 3
+tab_width = 4
 
 # New line preferences
 end_of_line = crlf

src/Connected.ServiceModel.Client.Data/DataParameterCollection.cs

@@ -1,125 +1,61 @@
-using System.Collections;
+using System.Data;
-using System.Data.Common;
 
 namespace Connected.ServiceModel.Client.Data;
-internal sealed class DataParameterCollection : DbParameterCollection
+internal sealed class DataParameterCollection : List<IDbDataParameter>, IDataParameterCollection
 {
-	private readonly object _syncRoot = new();
+	public object this[string parameterName]
-	public DataParameterCollection()
 	{
-		Items = new();
+		get
-	}
-
-	private List<DbParameter> Items { get; }
-	public override int Count => Items.Count;
-
-	public override object SyncRoot => _syncRoot;
-
-	public override int Add(object value)
-	{
-		if (value is not DbParameter parameter)
-			throw new InvalidCastException(nameof(DbParameter));
-
-		Items.Add(parameter);
-
-		return Items.Count - 1;
-	}
-
-	public override void AddRange(Array values)
-	{
-		foreach (var item in values)
-			Add(item);
-	}
-
-	public override void Clear()
-	{
-		Items.Clear();
-	}
-
-	public override bool Contains(object value)
-	{
-		return Items.Contains(value);
-	}
-
-	public override bool Contains(string value)
-	{
-		return Items.FirstOrDefault(f => string.Equals(f.ParameterName, value, StringComparison.OrdinalIgnoreCase)) is not null;
-	}
-
-	public override void CopyTo(Array array, int index)
-	{
-		foreach (var item in array)
 		{
-			Insert(index, item);
+			foreach (var parameter in this)
-			index++;
+			{
+				if (string.Equals(parameter.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
+					return parameter;
+			}
+
+			throw new NullReferenceException(nameof(IDbDataParameter));
+		}
+		set
+		{
+			if (value is not IDbDataParameter parameter)
+				throw new InvalidCastException(nameof(IDbDataParameter));
+
+			var idx = IndexOf(parameterName);
+
+			if (idx < 0)
+				throw new NullReferenceException(nameof(IDbDataParameter));
+
+			this[idx] = parameter;
 		}
 	}
 
-	public override IEnumerator GetEnumerator()
+	public bool Contains(string parameterName)
 	{
-		return Items.GetEnumerator();
+		foreach (var parameter in this)
+		{
+			if (string.Equals(parameter.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
+				return true;
+		}
+
+		return false;
 	}
 
-	public override int IndexOf(object value)
+	public int IndexOf(string parameterName)
 	{
-		if (value is not DbParameter parameter)
+		for (var i = 0; i < Count; i++)
-			throw new InvalidCastException(nameof(DbParameter));
+		{
+			var current = this[i];
 
-		return Items.IndexOf(parameter);
+			if (string.Equals(current.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
-	}
+				return i;
-
+		}
-	public override int IndexOf(string parameterName)
-	{
-		if (Items.FirstOrDefault(f => string.Equals(f.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase)) is DbParameter parameter)
-			return Items.IndexOf(parameter);
 
 		return -1;
 	}
 
-	public override void Insert(int index, object value)
+	public void RemoveAt(string parameterName)
 	{
-		if (value is not DbParameter parameter)
+		if (this[parameterName] is IDbDataParameter target)
-			throw new InvalidCastException(nameof(DbParameter));
+			Remove(target);
-
-		Items.Insert(index, parameter);
-	}
-
-	public override void Remove(object value)
-	{
-		if (value is not DbParameter parameter)
-			throw new InvalidCastException(nameof(DbParameter));
-
-		Items.Remove(parameter);
-	}
-
-	public override void RemoveAt(int index)
-	{
-		Items.RemoveAt(index);
-	}
-
-	public override void RemoveAt(string parameterName)
-	{
-		if (Items.FirstOrDefault(f => string.Equals(f.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase)) is DbParameter parameter)
-			Items.Remove(parameter);
-	}
-
-	protected override DbParameter GetParameter(int index)
-	{
-		return Items[index];
-	}
-
-	protected override DbParameter GetParameter(string parameterName)
-	{
-		return Items.First(f => string.Equals(f.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase));
-	}
-
-	protected override void SetParameter(int index, DbParameter value)
-	{
-		Items[index] = value;
-	}
-
-	protected override void SetParameter(string parameterName, DbParameter value)
-	{
-		Items[IndexOf(parameterName)] = value;
 	}
 }

src/Connected.ServiceModel.Client.Data/TableConnection.cs

@@ -1,5 +1,4 @@
 using System.Data;
-using System.Diagnostics.CodeAnalysis;
 using Connected.ServiceModel.Client.Data.Remote;
 
 namespace Connected.ServiceModel.Client.Data;
@@ -19,7 +18,6 @@ internal sealed class TableConnection : IDbConnection
 	/// <summary>
 	/// The connection string (URL) used when performing the requests. 
 	/// </summary>
-	[AllowNull]
 	public string ConnectionString { get; set; }
 	/// <summary>
 	/// The request timeout in seconds.

src/Connected.ServiceModel.Client.Data/TableDataCommand.cs

@@ -1,96 +1,64 @@
 using System.Data;
-using System.Data.Common;
-using System.Diagnostics.CodeAnalysis;
-using System.Text;
 using Connected.ServiceModel.Client.Data.Remote;
 
 namespace Connected.ServiceModel.Client.Data;
-internal sealed class TableDataCommand : DbCommand
+internal sealed class TableDataCommand : IDbCommand
 {
 	public TableDataCommand(RemoteTableService tables)
 	{
 		Parameters = new DataParameterCollection();
 		Tables = tables;
 	}
+	public string CommandText { get; set; }
+	public int CommandTimeout { get; set; }
+	public CommandType CommandType { get; set; }
+	public IDbConnection? Connection { get; set; }
 
-	public new DataParameterCollection Parameters { get; }
+	public IDataParameterCollection Parameters { get; }
+
+	public IDbTransaction? Transaction { get; set; }
+	public UpdateRowSource UpdatedRowSource { get; set; }
 	public RemoteTableService Tables { get; }
-	[AllowNull]
-	public override string CommandText { get; set; }
-	public override int CommandTimeout { get; set; } = 120;
-	public override CommandType CommandType { get; set; } = CommandType.Text;
-	protected override DbConnection? DbConnection { get; set; }
-	protected override DbParameterCollection DbParameterCollection => Parameters;
-	protected override DbTransaction? DbTransaction { get; set; }
-	public override bool DesignTimeVisible { get; set; }
-	public override UpdateRowSource UpdatedRowSource { get; set; }
 
-	protected override DbParameter CreateDbParameter()
+	public void Cancel()
+	{
+
+	}
+
+	public IDbDataParameter CreateParameter()
 	{
 		return new TableDataParameter();
 	}
 
-	public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken)
+	public void Dispose()
 	{
-		await Tables.Update(ParseCommandText());
+
+	}
+
+	public int ExecuteNonQuery()
+	{
+		AsyncUtils.RunSync(() => Tables.Update(CommandText));
 
 		return 0;
 	}
 
-	public override int ExecuteNonQuery()
+	public IDataReader ExecuteReader()
 	{
-		AsyncUtils.RunSync(() => Tables.Update(ParseCommandText()));
+		return new TableDataReader(AsyncUtils.RunSync(() => Tables.Query(CommandText)));
-
-		return 0;
 	}
 
-	protected override async Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior, CancellationToken cancellationToken)
+	public IDataReader ExecuteReader(CommandBehavior behavior)
 	{
-		return new TableDataReader(await Tables.Query(ParseCommandText()));
+		return new TableDataReader(AsyncUtils.RunSync(() => Tables.Query(CommandText)));
 	}
 
-	protected override DbDataReader ExecuteDbDataReader(CommandBehavior behavior)
+	public object? ExecuteScalar()
 	{
-		return new TableDataReader(AsyncUtils.RunSync(() => Tables.Query(ParseCommandText())));
+		throw new NotImplementedException();
 	}
 
-	private string ParseCommandText()
+	public void Prepare()
-	{
-		var text = new StringBuilder(CommandText);
-
-		foreach (IDbDataParameter parameter in Parameters)
-			text = text.Replace(parameter.ParameterName, ParseValue(parameter));
-
-		return text.ToString();
-	}
-
-	private static string? ParseValue(IDbDataParameter parameter)
-	{
-		if (parameter.Value is null || parameter.Value == DBNull.Value)
-			return "null";
-
-		return parameter.DbType switch
-		{
-			DbType.AnsiString or DbType.String or DbType.AnsiStringFixedLength or DbType.StringFixedLength or DbType.Xml => $"'{parameter.Value}'",
-			_ => parameter.Value.ToString(),
-		};
-	}
-
-	public override void Cancel()
-	{
-	}
-
-	public override object? ExecuteScalar()
-	{
-		var reader = ExecuteReader();
-
-		if (reader.Read())
-			return reader[0];
-
-		return null;
-	}
-
-	public override void Prepare()
 	{
+		throw new NotImplementedException();
 	}
 }

src/Connected.ServiceModel.Client.Data/TableDataConnection.cs

@@ -1,8 +1,8 @@
 using System.Data;
-using System.Data.Common;
 using Connected.Annotations;
 using Connected.Data.Storage;
 using Connected.ServiceModel.Client.Data.Remote;
+using Microsoft.Data.SqlClient;
 
 namespace Connected.ServiceModel.Client.Data;
 
@@ -19,7 +19,7 @@ internal sealed class TableDataConnection : DatabaseConnection
 	{
 		if (cmd.Parameters.Count > 0)
 		{
-			foreach (DbParameter i in cmd.Parameters)
+			foreach (SqlParameter i in cmd.Parameters)
 				i.Value = DBNull.Value;
 
 			return;
@@ -30,7 +30,7 @@ internal sealed class TableDataConnection : DatabaseConnection
 
 		foreach (var i in command.Operation.Parameters)
 		{
-			cmd.Parameters.Add(new TableDataParameter
+			cmd.Parameters.Add(new SqlParameter
 			{
 				ParameterName = i.Name,
 				DbType = i.Type,
@@ -39,17 +39,17 @@ internal sealed class TableDataConnection : DatabaseConnection
 		}
 	}
 
-	protected override object? GetParameterValue(IDbCommand command, string parameterName)
+	protected override object GetParameterValue(IDbCommand command, string parameterName)
 	{
-		if (command is TableDataCommand cmd)
+		if (command is SqlCommand cmd)
 			return cmd.Parameters[parameterName].Value;
 
 		return null;
 	}
 
-	protected override void SetParameterValue(IDbCommand command, string parameterName, object? value)
+	protected override void SetParameterValue(IDbCommand command, string parameterName, object value)
 	{
-		if (command is TableDataCommand cmd)
+		if (command is SqlCommand cmd)
 			cmd.Parameters[parameterName].Value = value;
 	}
 

src/Connected.ServiceModel.Client.Data/TableDataParameter.cs

@@ -1,20 +1,16 @@
 using System.Data;
-using System.Data.Common;
 
 namespace Connected.ServiceModel.Client.Data;
-internal class TableDataParameter : DbParameter
+internal class TableDataParameter : IDbDataParameter
 {
-	public override DbType DbType { get; set; }
+	public byte Precision { get; set; }
-	public override ParameterDirection Direction { get; set; }
+	public byte Scale { get; set; }
-	public override bool IsNullable { get; set; }
+	public int Size { get; set; }
-	public override string? ParameterName { get; set; }
+	public DbType DbType { get; set; }
-	public override int Size { get; set; }
+	public ParameterDirection Direction { get; set; }
-	public override string? SourceColumn { get; set; }
+	public bool IsNullable { get; set; }
-	public override bool SourceColumnNullMapping { get; set; }
+	public string ParameterName { get; set; }
-	public override object? Value { get; set; }
+	public string SourceColumn { get; set; }
-
+	public DataRowVersion SourceVersion { get; set; }
-	public override void ResetDbType()
+	public object? Value { get; set; }
-	{
-
-	}
 }

src/Connected.ServiceModel.Client.Data/TableDataReader.cs

@@ -1,221 +1,164 @@
-using System.Collections;
+using System.Data;
-using System.Data.Common;
 using System.Diagnostics.CodeAnalysis;
 using System.Text.Json.Nodes;
 
 namespace Connected.ServiceModel.Client.Data;
-internal sealed class TableDataReader : DbDataReader
+internal sealed class TableDataReader : IDataReader
 {
 	public TableDataReader(JsonArray items)
 	{
 		Items = items;
 	}
 
-	public override object this[int ordinal] => throw new NotImplementedException();
+	public object this[int i] => throw new NotImplementedException();
 
-	public override object this[string name] => throw new NotImplementedException();
+	public object this[string name] => throw new NotImplementedException();
 
-	private JsonArray Items { get; }
+	public int Depth => throw new NotImplementedException();
-	private int Index { get; set; } = -1;
-	private JsonObject? Current => Index < 0 ? null : Items[Index] as JsonObject;
-	public override int Depth => 1;
-	public override int FieldCount => Current is null ? 0 : Current.Count;
 
-	public override bool HasRows => Items.Any();
+	public bool IsClosed => throw new NotImplementedException();
 
-	public override bool IsClosed => false;
+	public int RecordsAffected => throw new NotImplementedException();
 
-	public override int RecordsAffected => Items.Count;
+	public int FieldCount => throw new NotImplementedException();
 
-	public override bool GetBoolean(int ordinal)
+	public JsonArray Items { get; }
+
+	public void Close()
 	{
-		return GetValue<bool>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override byte GetByte(int ordinal)
+	public void Dispose()
 	{
-		return GetValue<byte>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override long GetBytes(int ordinal, long dataOffset, byte[]? buffer, int bufferOffset, int length)
+	public bool GetBoolean(int i)
 	{
-		var value = GetValue<string>(ordinal);
+		throw new NotImplementedException();
-		var bytes = Convert.FromBase64String(value);
-
-		buffer ??= new byte[bufferOffset + length];
-
-		for (var i = 0; i < length; i++)
-			buffer[bufferOffset + i] = bytes[dataOffset + i];
-
-		return length;
 	}
 
-	public override char GetChar(int ordinal)
+	public byte GetByte(int i)
 	{
-		return GetValue<char>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override long GetChars(int ordinal, long dataOffset, char[]? buffer, int bufferOffset, int length)
+	public long GetBytes(int i, long fieldOffset, byte[]? buffer, int bufferoffset, int length)
 	{
-		var value = GetValue<string>(ordinal);
+		throw new NotImplementedException();
-		var bytes = Convert.FromBase64String(value);
-
-		buffer ??= new char[bufferOffset + length];
-
-		for (var i = 0; i < length; i++)
-			buffer[bufferOffset + i] = (char)bytes[dataOffset + i];
-
-		return length;
 	}
 
-	public override string GetDataTypeName(int ordinal)
+	public char GetChar(int i)
 	{
-		/*
+		throw new NotImplementedException();
-		 * TODO: resolve appropriate type
-		 */
-		return typeof(string).Name;
 	}
 
-	public override DateTime GetDateTime(int ordinal)
+	public long GetChars(int i, long fieldoffset, char[]? buffer, int bufferoffset, int length)
 	{
-		return GetValue<DateTime>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override decimal GetDecimal(int ordinal)
+	public IDataReader GetData(int i)
 	{
-		return GetValue<decimal>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override double GetDouble(int ordinal)
+	public string GetDataTypeName(int i)
 	{
-		return GetValue<double>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override IEnumerator GetEnumerator()
+	public DateTime GetDateTime(int i)
 	{
-		return Items.GetEnumerator();
+		throw new NotImplementedException();
+	}
+
+	public decimal GetDecimal(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public double GetDouble(int i)
+	{
+		throw new NotImplementedException();
 	}
 
 	[return: DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicFields | DynamicallyAccessedMemberTypes.PublicProperties)]
-	public override Type GetFieldType(int ordinal)
+	public Type GetFieldType(int i)
 	{
-		/*
+		throw new NotImplementedException();
-		 * TODO: resolve appropriate type
-		 */
-		return typeof(string);
 	}
 
-	public override float GetFloat(int ordinal)
+	public float GetFloat(int i)
 	{
-		return GetValue<float>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override Guid GetGuid(int ordinal)
+	public Guid GetGuid(int i)
 	{
-		return GetValue<Guid>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override short GetInt16(int ordinal)
+	public short GetInt16(int i)
 	{
-		return GetValue<short>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override int GetInt32(int ordinal)
+	public int GetInt32(int i)
 	{
-		return GetValue<int>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override long GetInt64(int ordinal)
+	public long GetInt64(int i)
 	{
-		return GetValue<long>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override string GetName(int ordinal)
+	public string GetName(int i)
 	{
-		if (Current is null)
+		throw new NotImplementedException();
-			throw new NullReferenceException();
-
-		if (Current.ElementAt(ordinal).Key is string key)
-			return key;
-
-		throw new NullReferenceException();
 	}
 
-	public override int GetOrdinal(string name)
+	public int GetOrdinal(string name)
 	{
-		if (Current is null)
+		throw new NotImplementedException();
-			throw new NullReferenceException();
-
-		for (var i = 0; i < Current.Count; i++)
-		{
-			if (string.Equals(Current.ElementAt(i).Key, name, StringComparison.OrdinalIgnoreCase))
-				return i;
-		}
-
-		return -1;
 	}
 
-	public override string GetString(int ordinal)
+	public DataTable? GetSchemaTable()
 	{
-		return GetValue<string>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override object GetValue(int ordinal)
+	public string GetString(int i)
 	{
-		return GetValue<object>(ordinal);
+		throw new NotImplementedException();
 	}
 
-	public override int GetValues(object[] values)
+	public object GetValue(int i)
 	{
-		if (Current is null)
+		throw new NotImplementedException();
-			throw new NullReferenceException();
-
-		for (var i = 0; i < Current.Count; i++)
-		{
-			var value = Current.ElementAt(i);
-
-			if (value.Value is not null)
-				values[i] = value.Value.AsValue().GetValue<object>();
-		}
-
-		return Current.Count;
 	}
 
-	public override bool IsDBNull(int ordinal)
+	public int GetValues(object[] values)
 	{
-		return false;
+		throw new NotImplementedException();
 	}
 
-	public override bool NextResult()
+	public bool IsDBNull(int i)
 	{
-		return false;
+		throw new NotImplementedException();
 	}
 
-	public override bool Read()
+	public bool NextResult()
 	{
-		if (Items.Count >= Index + 1)
+		throw new NotImplementedException();
-		{
+	}
-			Index++;
 
-			return true;
+	public bool Read()
-		}
+	{
+		//var items = AsyncUtils.RunSync(() => Service.Query(CommandText));
 
 		return false;
 	}
-
-	private T GetValue<T>(int ordinal)
-	{
-		return GetCurrentValue(ordinal).GetValue<T>();
-	}
-
-	private JsonValue GetCurrentValue(int ordinal)
-	{
-		if (Current is null)
-			throw new NullReferenceException();
-
-		if (Current.ElementAt(ordinal).Value is not JsonValue value)
-			throw new NullReferenceException();
-
-		return value;
-	}
 }

src/Connected.ServiceModel.Client.Data/TableReader.cs

@@ -67,7 +67,7 @@ internal sealed class TableReader<T> : TableCommand, IStorageReader<T>
 	public async Task<IDataReader> OpenReader()
 	{
 		if (Connection is null)
-			throw new NullReferenceException(nameof(Connection));
+			return default;
 
 		return await Connection.OpenReader(this);
 	}

src/Connected.ServiceModel.Client/Net/ConnectedServerOps.cs

@@ -2,9 +2,9 @@
 
 namespace Connected.ServiceModel.Client.Net;
 
-internal sealed class SelectUrl : ServiceFunction<ConnectedServerUrlArgs, string?>
+internal sealed class SelectUrl : ServiceFunction<ConnectedServerUrlArgs, string>
 {
-	private const string Root = "https://localhost:7069";//"https://connected.tompit.com";
+	private const string Root = "https://localhost:61599";//"https://connected.tompit.com";
 	protected override async Task<string?> OnInvoke()
 	{
 		await Task.CompletedTask;