@@ -64,24 +64,24 @@ public void CompleteDatabaseInfoTest()
64
64
}
65
65
66
66
[ Test ]
67
- public void PerformanceAnalysis_SELECT_Test ( )
67
+ public async Task PerformanceAnalysis_SELECT_Test ( )
68
68
{
69
69
IDictionary < string , short > tableNameList = GetTableNameList ( ) ;
70
70
short tableIdTest = tableNameList [ "TEST" ] ;
71
71
72
72
var dbInfo = new FbDatabaseInfo ( Connection ) ;
73
- IDictionary < short , ulong > insertCount = dbInfo . GetInsertCount ( ) ;
74
- IDictionary < short , ulong > updateCount = dbInfo . GetUpdateCount ( ) ;
75
- IDictionary < short , ulong > readSeqCount = dbInfo . GetReadSeqCount ( ) ;
76
- IDictionary < short , ulong > readIdxCount = dbInfo . GetReadIdxCount ( ) ;
73
+ var insertCount = await dbInfo . GetInsertCountAsync ( ) ;
74
+ var updateCount = await dbInfo . GetUpdateCountAsync ( ) ;
75
+ var readSeqCount = await dbInfo . GetReadSeqCountAsync ( ) ;
76
+ var readIdxCount = await dbInfo . GetReadIdxCountAsync ( ) ;
77
77
78
78
var fbCommand = new FbCommand ( "SELECT MAX(INT_FIELD) FROM TEST" , Connection ) ;
79
- var maxIntField = fbCommand . ExecuteScalar ( ) as int ? ;
79
+ var maxIntField = await fbCommand . ExecuteScalarAsync ( ) as int ? ;
80
80
81
- insertCount = GetAffectedTables ( insertCount , dbInfo . GetInsertCount ( ) ) ;
82
- updateCount = GetAffectedTables ( updateCount , dbInfo . GetUpdateCount ( ) ) ;
83
- readSeqCount = GetAffectedTables ( readSeqCount , dbInfo . GetReadSeqCount ( ) ) ;
84
- readIdxCount = GetAffectedTables ( readIdxCount , dbInfo . GetReadIdxCount ( ) ) ;
81
+ insertCount = GetAffectedTables ( insertCount , await dbInfo . GetInsertCountAsync ( ) ) ;
82
+ updateCount = GetAffectedTables ( updateCount , await dbInfo . GetUpdateCountAsync ( ) ) ;
83
+ readSeqCount = GetAffectedTables ( readSeqCount , await dbInfo . GetReadSeqCountAsync ( ) ) ;
84
+ readIdxCount = GetAffectedTables ( readIdxCount , await dbInfo . GetReadIdxCountAsync ( ) ) ;
85
85
86
86
Assert . That ( insertCount . ContainsKey ( tableIdTest ) , Is . False ) ;
87
87
Assert . That ( updateCount . ContainsKey ( tableIdTest ) , Is . False ) ;
@@ -91,24 +91,24 @@ public void PerformanceAnalysis_SELECT_Test()
91
91
}
92
92
93
93
[ Test ]
94
- public void PerformanceAnalysis_INSERT_Test ( )
94
+ public async Task PerformanceAnalysis_INSERT_Test ( )
95
95
{
96
96
IDictionary < string , short > tableNameList = GetTableNameList ( ) ;
97
97
short tableIdTest = tableNameList [ "TEST" ] ;
98
98
99
99
var dbInfo = new FbDatabaseInfo ( Connection ) ;
100
- IDictionary < short , ulong > insertCount = dbInfo . GetInsertCount ( ) ;
101
- IDictionary < short , ulong > updateCount = dbInfo . GetUpdateCount ( ) ;
102
- IDictionary < short , ulong > readSeqCount = dbInfo . GetReadSeqCount ( ) ;
103
- IDictionary < short , ulong > readIdxCount = dbInfo . GetReadIdxCount ( ) ;
100
+ var insertCount = await dbInfo . GetInsertCountAsync ( ) ;
101
+ var updateCount = await dbInfo . GetUpdateCountAsync ( ) ;
102
+ var readSeqCount = await dbInfo . GetReadSeqCountAsync ( ) ;
103
+ var readIdxCount = await dbInfo . GetReadIdxCountAsync ( ) ;
104
104
105
105
var fbCommand = new FbCommand ( "INSERT INTO TEST (INT_FIELD) VALUES (900)" , Connection ) ;
106
- fbCommand . ExecuteNonQuery ( ) ;
106
+ await fbCommand . ExecuteNonQueryAsync ( ) ;
107
107
108
- insertCount = GetAffectedTables ( insertCount , dbInfo . GetInsertCount ( ) ) ;
109
- updateCount = GetAffectedTables ( updateCount , dbInfo . GetUpdateCount ( ) ) ;
110
- readSeqCount = GetAffectedTables ( readSeqCount , dbInfo . GetReadSeqCount ( ) ) ;
111
- readIdxCount = GetAffectedTables ( readIdxCount , dbInfo . GetReadIdxCount ( ) ) ;
108
+ insertCount = GetAffectedTables ( insertCount , await dbInfo . GetInsertCountAsync ( ) ) ;
109
+ updateCount = GetAffectedTables ( updateCount , await dbInfo . GetUpdateCountAsync ( ) ) ;
110
+ readSeqCount = GetAffectedTables ( readSeqCount , await dbInfo . GetReadSeqCountAsync ( ) ) ;
111
+ readIdxCount = GetAffectedTables ( readIdxCount , await dbInfo . GetReadIdxCountAsync ( ) ) ;
112
112
113
113
Assert . That ( insertCount . ContainsKey ( tableIdTest ) , Is . True ) ;
114
114
Assert . That ( insertCount [ tableIdTest ] , Is . EqualTo ( 1 ) ) ;
@@ -118,7 +118,7 @@ public void PerformanceAnalysis_INSERT_Test()
118
118
}
119
119
120
120
[ Test ]
121
- public void PerformanceAnalysis_UPDATE_Test ( )
121
+ public async Task PerformanceAnalysis_UPDATE_Test ( )
122
122
{
123
123
IDictionary < string , short > tableNameList = GetTableNameList ( ) ;
124
124
short tableIdTest = tableNameList [ "TEST" ] ;
@@ -127,18 +127,18 @@ public void PerformanceAnalysis_UPDATE_Test()
127
127
fbCommand . ExecuteNonQuery ( ) ;
128
128
129
129
var dbInfo = new FbDatabaseInfo ( Connection ) ;
130
- IDictionary < short , ulong > insertCount = dbInfo . GetInsertCount ( ) ;
131
- IDictionary < short , ulong > updateCount = dbInfo . GetUpdateCount ( ) ;
132
- IDictionary < short , ulong > readSeqCount = dbInfo . GetReadSeqCount ( ) ;
133
- IDictionary < short , ulong > readIdxCount = dbInfo . GetReadIdxCount ( ) ;
130
+ var insertCount = await dbInfo . GetInsertCountAsync ( ) ;
131
+ var updateCount = await dbInfo . GetUpdateCountAsync ( ) ;
132
+ var readSeqCount = await dbInfo . GetReadSeqCountAsync ( ) ;
133
+ var readIdxCount = await dbInfo . GetReadIdxCountAsync ( ) ;
134
134
135
135
fbCommand . CommandText = "UPDATE TEST SET SMALLINT_FIELD = 900 WHERE (INT_FIELD = 900)" ;
136
- fbCommand . ExecuteNonQuery ( ) ;
136
+ await fbCommand . ExecuteNonQueryAsync ( ) ;
137
137
138
- insertCount = GetAffectedTables ( insertCount , dbInfo . GetInsertCount ( ) ) ;
139
- updateCount = GetAffectedTables ( updateCount , dbInfo . GetUpdateCount ( ) ) ;
140
- readSeqCount = GetAffectedTables ( readSeqCount , dbInfo . GetReadSeqCount ( ) ) ;
141
- readIdxCount = GetAffectedTables ( readIdxCount , dbInfo . GetReadIdxCount ( ) ) ;
138
+ insertCount = GetAffectedTables ( insertCount , await dbInfo . GetInsertCountAsync ( ) ) ;
139
+ updateCount = GetAffectedTables ( updateCount , await dbInfo . GetUpdateCountAsync ( ) ) ;
140
+ readSeqCount = GetAffectedTables ( readSeqCount , await dbInfo . GetReadSeqCountAsync ( ) ) ;
141
+ readIdxCount = GetAffectedTables ( readIdxCount , await dbInfo . GetReadIdxCountAsync ( ) ) ;
142
142
143
143
Assert . That ( insertCount . ContainsKey ( tableIdTest ) , Is . False ) ;
144
144
Assert . That ( updateCount . ContainsKey ( tableIdTest ) , Is . True ) ;
@@ -157,7 +157,9 @@ private IDictionary<short, ulong> GetAffectedTables(IDictionary<short, ulong> aS
157
157
{
158
158
ulong counter = keyValuePair . Value - value ;
159
159
if ( counter > 0 )
160
+ {
160
161
result . Add ( keyValuePair . Key , counter ) ;
162
+ }
161
163
}
162
164
else
163
165
result . Add ( keyValuePair . Key , keyValuePair . Value ) ;
0 commit comments