mirrors/lemmy
1
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-29 12:51:03 +00:00
Code Issues Projects Releases Wiki Activity

different timestamps

Browse source
This commit is contained in:
dull b 2023-12-20 21:20:56 +00:00
parent ad2af54384
commit 191e2f0c57
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
crates/db_perf/src/main.rs
View file

@ -1,5 +1,5 @@
use clap::{Parser, Subcommand}; use clap::{Parser, Subcommand};
use diesel::{dsl, sql_query, sql_types, ExpressionMethods, IntoSql}; use diesel::{dsl::{self, sql}, sql_query, sql_types, ExpressionMethods, IntoSql};
use diesel_async::RunQueryDsl; use diesel_async::RunQueryDsl;
use lemmy_db_schema::{ use lemmy_db_schema::{
schema::post, schema::post,
@ -12,7 +12,7 @@ use lemmy_db_schema::{
utils::{ utils::{
build_db_pool, build_db_pool,
get_conn, get_conn,
series::{self, ValuesFromSeries}, DbConn, DbPool, series::{self, ValuesFromSeries}, DbConn, DbPool, now,
}, },
SortType, SortType,
}; };
@ -22,6 +22,7 @@ use lemmy_db_views::{
}; };
use lemmy_utils::error::LemmyResult; use lemmy_utils::error::LemmyResult;
use std::num::NonZeroU32; use std::num::NonZeroU32;
use diesel::pg::expression::dsl::IntervalDsl;
#[derive(Parser, Debug)] #[derive(Parser, Debug)]
struct CmdArgs { struct CmdArgs {
@ -107,6 +108,7 @@ async fn main() -> LemmyResult<()> {
person_id.into_sql::<sql_types::Integer>(), person_id.into_sql::<sql_types::Integer>(),
community_id.into_sql::<sql_types::Integer>(), community_id.into_sql::<sql_types::Integer>(),
series::current_value.eq(1), series::current_value.eq(1),
now() - sql::<sql_types::Interval>("make_interval(secs => ").bind::<sql_types::BigInt, _>(series::current_value).sql(")"),
), ),
}) })
.into_columns(( .into_columns((
@ -114,6 +116,7 @@ async fn main() -> LemmyResult<()> {
post::creator_id, post::creator_id,
post::community_id, post::community_id,
post::featured_community, post::featured_community,
post::published,
)) ))
.execute(&mut get_conn(pool).await?) .execute(&mut get_conn(pool).await?)
.await?; .await?;