46 lines
No EOL
1.5 KiB
C#
46 lines
No EOL
1.5 KiB
C#
using System.Threading.Tasks;
|
|
using System.Linq;
|
|
using Dapper;
|
|
using Website.Models;
|
|
using Website.Data.States;
|
|
using System.Collections.Generic;
|
|
|
|
namespace Website.Data
|
|
{
|
|
public class BlogRepository
|
|
{
|
|
private readonly IDatabaseProvider _dbProvider;
|
|
|
|
public BlogRepository(IDatabaseProvider dbProvider) => _dbProvider = dbProvider;
|
|
|
|
public async Task<BlogPost> GetPostByUrlAsync(string url) {
|
|
const string query = "SELECT * FROM blog_posts WHERE post_url=@url AND post_deleted=0";
|
|
using (var connection = _dbProvider.NewConnection()) {
|
|
connection.Open();
|
|
var result = await connection.QueryAsync<BlogPostState>(query, new{url});
|
|
return new BlogPost(result.First());
|
|
}
|
|
}
|
|
|
|
public async Task<IEnumerable<BlogPost>> GetLatestPostsAsync(int limit, int offset) {
|
|
const string query = "SELECT * FROM blog_posts WHERE post_content<>'' AND post_deleted=0 ORDER BY post_timestamp DESC LIMIT @offset,@limit";
|
|
using (var connection = _dbProvider.NewConnection()) {
|
|
connection.Open();
|
|
var results = await connection.QueryAsync<BlogPostState>(query, new{limit, offset});
|
|
return results.Select(result => new BlogPost(result));
|
|
}
|
|
}
|
|
|
|
public async Task<BlogPost> GetLatestPostAsync() => (await GetLatestPostsAsync(1, 0)).First();
|
|
|
|
public async Task<int> GetCountAsync()
|
|
{
|
|
var query="SELECT COUNT(*) FROM blog_posts WHERE post_content<>'' AND post_deleted=0";
|
|
using(var connection = _dbProvider.NewConnection()) {
|
|
connection.Open();
|
|
var result = await connection.QueryAsync<int>(query);
|
|
return result.First();
|
|
}
|
|
}
|
|
}
|
|
} |