glenux-archive/cloutier--bird.makeup
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

switched to vanilla npgsql for some queries

Browse source
This commit is contained in:
Vincent Cloutier 2022-12-30 14:55:12 -05:00
parent def5649097
commit 4ea8868b7b
2 changed files with 40 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/DataAccessLayers/BirdsiteLive.DAL.Postgres/BirdsiteLive.DAL.Postgres.csproj
View file

@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk"> <Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup> <PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework> <TargetFramework>net6.0</TargetFramework>
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>

49
src/DataAccessLayers/BirdsiteLive.DAL.Postgres/DataAccessLayers/TwitterUserPostgresDal.cs
View file

@ -33,26 +33,55 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers
public async Task<SyncTwitterUser> GetTwitterUserAsync(string acct) public async Task<SyncTwitterUser> GetTwitterUserAsync(string acct)
{ {
var query = $"SELECT * FROM {_settings.TwitterUserTableName} WHERE acct = @acct"; var query = $"SELECT * FROM {_settings.TwitterUserTableName} WHERE acct = $1";
acct = acct.ToLowerInvariant(); acct = acct.ToLowerInvariant();
using (var dbConnection = Connection) await using var connection = DataSource.CreateConnection();
await connection.OpenAsync();
await using var command = new NpgsqlCommand(query, connection) {
Parameters = { new() { Value = acct}}
};
var reader = await command.ExecuteReaderAsync();
if (!await reader.ReadAsync())
return null;
return new SyncTwitterUser
{ {
var result = (await dbConnection.QueryAsync<SyncTwitterUser>(query, new { acct })).FirstOrDefault(); Id = reader["id"] as int? ?? default,
return result; Acct = reader["acct"] as string,
} TwitterUserId = reader["twitterUserId"] as long? ?? default,
LastTweetPostedId = reader["lastTweetPostedId"] as long? ?? default,
LastTweetSynchronizedForAllFollowersId = reader["lastTweetSynchronizedForAllFollowersId"] as long? ?? default,
LastSync = reader["lastSync"] as DateTime? ?? default,
FetchingErrorCount = reader["fetchingErrorCount"] as int? ?? default,
};
} }
public async Task<SyncTwitterUser> GetTwitterUserAsync(int id) public async Task<SyncTwitterUser> GetTwitterUserAsync(int id)
{ {
var query = $"SELECT * FROM {_settings.TwitterUserTableName} WHERE id = @id"; var query = $"SELECT * FROM {_settings.TwitterUserTableName} WHERE id = $1";
using (var dbConnection = Connection) await using var connection = DataSource.CreateConnection();
await connection.OpenAsync();
await using var command = new NpgsqlCommand(query, connection) {
Parameters = { new() { Value = id}}
};
var reader = await command.ExecuteReaderAsync();
if (!await reader.ReadAsync())
return null;
return new SyncTwitterUser
{ {
var result = (await dbConnection.QueryAsync<SyncTwitterUser>(query, new { id })).FirstOrDefault(); Id = reader["id"] as int? ?? default,
return result; Acct = reader["acct"] as string,
} TwitterUserId = reader["twitterUserId"] as long? ?? default,
LastTweetPostedId = reader["lastTweetPostedId"] as long? ?? default,
LastTweetSynchronizedForAllFollowersId = reader["lastTweetSynchronizedForAllFollowersId"] as long? ?? default,
LastSync = reader["lastSync"] as DateTime? ?? default,
FetchingErrorCount = reader["fetchingErrorCount"] as int? ?? default,
};
} }
public async Task<int> GetTwitterUsersCountAsync() public async Task<int> GetTwitterUsersCountAsync()