@@ -45,14 +45,10 @@ FROM [users].[{tableName}] e INNER JOIN emp
4545 SELECT *
4646 FROM emp e { depthQuery } { filterQuery } " ;
4747
48- var credential = new DefaultAzureCredential ( ) ;
49- var token = await credential . GetTokenAsync ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
50-
5148 await retryPolicy . Execute ( async ( ) =>
5249 {
5350 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
5451 {
55- conn . AccessToken = token . Token ;
5652 await conn . OpenAsync ( ) ;
5753 using ( var cmd = new SqlCommand ( selectQuery , conn ) )
5854 {
@@ -110,14 +106,11 @@ FROM emp e
110106 " ;
111107
112108 var selectIdQuery = $ "SELECT EmployeeId FROM [users].[{ tableName } ] WHERE AzureObjectId = '{ azureObjectId } '";
113- var credential = new DefaultAzureCredential ( ) ;
114- var token = credential . GetToken ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
115109
116110 await retryPolicy . Execute ( async ( ) =>
117111 {
118112 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
119113 {
120- conn . AccessToken = token . Token ;
121114 await conn . OpenAsync ( ) ;
122115 using ( var cmd = new SqlCommand ( selectDepthQuery , conn ) )
123116 {
@@ -166,13 +159,11 @@ public async Task<List<PersonEntity>> FilterChildEntitiesAsync(string query, str
166159 try
167160 {
168161 var selectQuery = $ "SELECT EmployeeId, AzureObjectId FROM [users].[{ tableName } ] WHERE { query } ";
169- var credential = new DefaultAzureCredential ( ) ;
170- var token = credential . GetToken ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
162+
171163 await retryPolicy . Execute ( async ( ) =>
172164 {
173165 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
174166 {
175- conn . AccessToken = token . Token ;
176167 await conn . OpenAsync ( ) ;
177168 using ( var cmd = new SqlCommand ( selectQuery , conn ) )
178169 {
@@ -210,14 +201,10 @@ public async Task<bool> CheckIfTableExistsAsync(string tableName)
210201 var retryPolicy = GetRetryPolicy ( ) ;
211202 try
212203 {
213- var credential = new DefaultAzureCredential ( ) ;
214- var token = credential . GetToken ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
215-
216204 await retryPolicy . Execute ( async ( ) =>
217205 {
218206 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
219207 {
220- conn . AccessToken = token . Token ;
221208 await conn . OpenAsync ( ) ;
222209 var selectQuery = $ "SELECT count(TABLE_NAME) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '{ tableName } ' AND TABLE_SCHEMA = 'users'";
223210 using ( var cmd = new SqlCommand ( selectQuery , conn ) )
@@ -244,13 +231,11 @@ public async Task<List<string>> GetColumnNamesAsync(string tableName)
244231 try
245232 {
246233 var selectQuery = $ "SELECT name FROM sys.columns WHERE object_id = OBJECT_ID('[users].[{ tableName } ]') ORDER BY name";
247- var credential = new DefaultAzureCredential ( ) ;
248- var token = credential . GetToken ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
234+
249235 await retryPolicy . Execute ( async ( ) =>
250236 {
251237 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
252238 {
253- conn . AccessToken = token . Token ;
254239 await conn . OpenAsync ( ) ;
255240 using ( var cmd = new SqlCommand ( selectQuery , conn ) )
256241 {
@@ -362,13 +347,10 @@ FROM sys.columns AS c
362347 WHERE c.object_id = OBJECT_ID('[users].[{ tableName } ]')
363348 ORDER BY c.name" ;
364349
365- var credential = new DefaultAzureCredential ( ) ;
366- var token = credential . GetToken ( new Azure . Core . TokenRequestContext ( new [ ] { "https://database.windows.net/.default" } ) ) ;
367350 await retryPolicy . Execute ( async ( ) =>
368351 {
369352 using ( var conn = new SqlConnection ( _sqlServerConnectionString ) )
370353 {
371- conn . AccessToken = token . Token ;
372354 await conn . OpenAsync ( ) ;
373355 using ( var cmd = new SqlCommand ( selectQuery , conn ) )
374356 {
0 commit comments