change avg period
This commit is contained in:
@@ -74,7 +74,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
let date = NaiveDate::parse_from_str(&args[1], "%Y-%m-%d").unwrap();
|
let date = NaiveDate::parse_from_str(&args[1], "%Y-%m-%d").unwrap();
|
||||||
let _ = aggregate_values(&mut conn, date);
|
let _ = aggregate_values(&mut conn, date);
|
||||||
}
|
}
|
||||||
dbg!(args);
|
//dbg!(args);
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
@@ -127,7 +127,7 @@ fn aggregate_values(conn: &mut PooledConn, date: NaiveDate) -> Result<(), Box<dy
|
|||||||
let query = "DELETE FROM donnees WHERE id IN (".to_owned() + &*ids.join(", ") + ");";
|
let query = "DELETE FROM donnees WHERE id IN (".to_owned() + &*ids.join(", ") + ");";
|
||||||
let _: Vec<Row> = conn.query(query)?;
|
let _: Vec<Row> = conn.query(query)?;
|
||||||
}
|
}
|
||||||
current_time = current_time + Duration::minutes(30);
|
current_time = current_time + Duration::minutes(15);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user