Added tests for determination of the number of reads, inserts, deletes etc

Author: DevM900

src/FirebirdSql.Data.FirebirdClient.Tests/FbDatabaseInfoTests.cs

@@ -16,6 +16,7 @@
 //$Authors = Carlos Guzman Alvarez, Jiri Cincura ([email protected])
 
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Reflection;
 using System.Threading;
@@ -61,4 +62,119 @@ public void CompleteDatabaseInfoTest()
 			Assert.DoesNotThrowAsync(() => (Task)m.Invoke(dbInfo, new object[] { CancellationToken.None }), m.Name);
 		}
 	}
+
+	[Test]
+	public void PerformanceAnalysis_SELECT_Test()
+	{
+		IDictionary<string, short> tableNameList = GetTableNameList();
+		short tableIdTest = tableNameList["TEST"];
+
+		var dbInfo = new FbDatabaseInfo(Connection);
+		IDictionary<short, ulong> insertCount = dbInfo.GetInsertCount();
+		IDictionary<short, ulong> updateCount = dbInfo.GetUpdateCount();
+		IDictionary<short, ulong> readSeqCount = dbInfo.GetReadSeqCount();
+		IDictionary<short, ulong> readIdxCount = dbInfo.GetReadIdxCount();
+
+		var fbCommand = new FbCommand("SELECT MAX(INT_FIELD) FROM TEST", Connection);
+		var maxIntField = fbCommand.ExecuteScalar() as int?;
+
+		insertCount = GetAffectedTables(insertCount, dbInfo.GetInsertCount());
+		updateCount = GetAffectedTables(updateCount, dbInfo.GetUpdateCount());
+		readSeqCount = GetAffectedTables(readSeqCount, dbInfo.GetReadSeqCount());
+		readIdxCount = GetAffectedTables(readIdxCount, dbInfo.GetReadIdxCount());
+
+		Assert.That(insertCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(updateCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(readSeqCount.ContainsKey(tableIdTest), Is.True);
+		Assert.That(readSeqCount[tableIdTest], Is.EqualTo(maxIntField + 1));
+		Assert.That(readIdxCount.ContainsKey(tableIdTest), Is.False);
+	}
+
+	[Test]
+	public void PerformanceAnalysis_INSERT_Test()
+	{
+		IDictionary<string, short> tableNameList = GetTableNameList();
+		short tableIdTest = tableNameList["TEST"];
+
+		var dbInfo = new FbDatabaseInfo(Connection);
+		IDictionary<short, ulong> insertCount = dbInfo.GetInsertCount();
+		IDictionary<short, ulong> updateCount = dbInfo.GetUpdateCount();
+		IDictionary<short, ulong> readSeqCount = dbInfo.GetReadSeqCount();
+		IDictionary<short, ulong> readIdxCount = dbInfo.GetReadIdxCount();
+
+		var fbCommand = new FbCommand("INSERT INTO TEST (INT_FIELD) VALUES (900)", Connection);
+		fbCommand.ExecuteNonQuery();
+
+		insertCount = GetAffectedTables(insertCount, dbInfo.GetInsertCount());
+		updateCount = GetAffectedTables(updateCount, dbInfo.GetUpdateCount());
+		readSeqCount = GetAffectedTables(readSeqCount, dbInfo.GetReadSeqCount());
+		readIdxCount = GetAffectedTables(readIdxCount, dbInfo.GetReadIdxCount());
+
+		Assert.That(insertCount.ContainsKey(tableIdTest), Is.True);
+		Assert.That(insertCount[tableIdTest], Is.EqualTo(1));
+		Assert.That(updateCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(readSeqCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(readIdxCount.ContainsKey(tableIdTest), Is.False);
+	}
+
+	[Test]
+	public void PerformanceAnalysis_UPDATE_Test()
+	{
+		IDictionary<string, short> tableNameList = GetTableNameList();
+		short tableIdTest = tableNameList["TEST"];
+
+		var fbCommand = new FbCommand("INSERT INTO TEST (INT_FIELD) VALUES (900)", Connection);
+		fbCommand.ExecuteNonQuery();
+
+		var dbInfo = new FbDatabaseInfo(Connection);
+		IDictionary<short, ulong> insertCount = dbInfo.GetInsertCount();
+		IDictionary<short, ulong> updateCount = dbInfo.GetUpdateCount();
+		IDictionary<short, ulong> readSeqCount = dbInfo.GetReadSeqCount();
+		IDictionary<short, ulong> readIdxCount = dbInfo.GetReadIdxCount();
+
+		fbCommand.CommandText = "UPDATE TEST SET SMALLINT_FIELD = 900 WHERE (INT_FIELD = 900)";
+		fbCommand.ExecuteNonQuery();
+
+		insertCount = GetAffectedTables(insertCount, dbInfo.GetInsertCount());
+		updateCount = GetAffectedTables(updateCount, dbInfo.GetUpdateCount());
+		readSeqCount = GetAffectedTables(readSeqCount, dbInfo.GetReadSeqCount());
+		readIdxCount = GetAffectedTables(readIdxCount, dbInfo.GetReadIdxCount());
+
+		Assert.That(insertCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(updateCount.ContainsKey(tableIdTest), Is.True);
+		Assert.That(updateCount[tableIdTest], Is.EqualTo(1));
+		Assert.That(readSeqCount.ContainsKey(tableIdTest), Is.False);
+		Assert.That(readIdxCount.ContainsKey(tableIdTest), Is.True);
+		Assert.That(readIdxCount[tableIdTest], Is.EqualTo(1));
+	}
+
+	private IDictionary<short, ulong> GetAffectedTables(IDictionary<short, ulong> aStatisticInfoBefore, IDictionary<short, ulong> aStatisticInfoAfter)
+	{
+		var result = new Dictionary<short, ulong>();
+		foreach (KeyValuePair<short, ulong> keyValuePair in aStatisticInfoAfter)
+		{
+			if (aStatisticInfoBefore.TryGetValue(keyValuePair.Key, out ulong value))
+			{
+				ulong counter = keyValuePair.Value - value;
+				if (counter > 0)
+					result.Add(keyValuePair.Key, counter);
+			}
+			else
+				result.Add(keyValuePair.Key, keyValuePair.Value);
+		}
+		return result;
+	}
+
+	private IDictionary<string, short> GetTableNameList()
+	{
+		IDictionary<string, short> result = new Dictionary<string, short>();
+
+		var command = new FbCommand("select R.RDB$RELATION_ID, R.RDB$RELATION_NAME from RDB$RELATIONS R WHERE RDB$SYSTEM_FLAG = 0", Connection);
+		FbDataReader reader = command.ExecuteReader();
+		while (reader.Read())
+		{
+			result.Add(reader.GetString(1).Trim(), reader.GetInt16(0));
+		}
+		return result;
+	}
 }