dnim/rust-postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

more clippy

Browse Source
This commit is contained in:
Steven Fackler 2021-08-10 21:17:50 -04:00
parent a8a35eb6db
commit 3e4be86531
4 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
postgres-types/src/lib.rs
View File

@ -909,7 +909,7 @@ impl<'a> ToSql for &'a str {
impl<'a> ToSql for Cow<'a, str> { impl<'a> ToSql for Cow<'a, str> {
fn to_sql(&self, ty: &Type, w: &mut BytesMut) -> Result<IsNull, Box<dyn Error + Sync + Send>> { fn to_sql(&self, ty: &Type, w: &mut BytesMut) -> Result<IsNull, Box<dyn Error + Sync + Send>> {
<&str as ToSql>::to_sql(&&self.as_ref(), ty, w) <&str as ToSql>::to_sql(&self.as_ref(), ty, w)
} }
fn accepts(ty: &Type) -> bool { fn accepts(ty: &Type) -> bool {

8
tokio-postgres/src/config.rs
View File

@ -390,19 +390,19 @@ impl Config {
fn param(&mut self, key: &str, value: &str) -> Result<(), Error> { fn param(&mut self, key: &str, value: &str) -> Result<(), Error> {
match key { match key {
"user" => { "user" => {
self.user(&value); self.user(value);
} }
"password" => { "password" => {
self.password(value); self.password(value);
} }
"dbname" => { "dbname" => {
self.dbname(&value); self.dbname(value);
} }
"options" => { "options" => {
self.options(&value); self.options(value);
} }
"application_name" => { "application_name" => {
self.application_name(&value); self.application_name(value);
} }
"sslmode" => { "sslmode" => {
let mode = match value { let mode = match value {

8
tokio-postgres/src/prepare.rs
View File

@ -86,7 +86,7 @@ pub async fn prepare(
let mut parameters = vec![]; let mut parameters = vec![];
let mut it = parameter_description.parameters(); let mut it = parameter_description.parameters();
while let Some(oid) = it.next().map_err(Error::parse)? { while let Some(oid) = it.next().map_err(Error::parse)? {
let type_ = get_type(&client, oid).await?; let type_ = get_type(client, oid).await?;
parameters.push(type_); parameters.push(type_);
} }
@ -94,13 +94,13 @@ pub async fn prepare(
if let Some(row_description) = row_description { if let Some(row_description) = row_description {
let mut it = row_description.fields(); let mut it = row_description.fields();
while let Some(field) = it.next().map_err(Error::parse)? { while let Some(field) = it.next().map_err(Error::parse)? {
let type_ = get_type(&client, field.type_oid()).await?; let type_ = get_type(client, field.type_oid()).await?;
let column = Column::new(field.name().to_string(), type_); let column = Column::new(field.name().to_string(), type_);
columns.push(column); columns.push(column);
} }
} }
Ok(Statement::new(&client, name, parameters, columns)) Ok(Statement::new(client, name, parameters, columns))
} }
fn prepare_rec<'a>( fn prepare_rec<'a>(
@ -120,7 +120,7 @@ fn encode(client: &InnerClient, name: &str, query: &str, types: &[Type]) -> Resu
client.with_buf(|buf| { client.with_buf(|buf| {
frontend::parse(name, query, types.iter().map(Type::oid), buf).map_err(Error::encode)?; frontend::parse(name, query, types.iter().map(Type::oid), buf).map_err(Error::encode)?;
frontend::describe(b'S', &name, buf).map_err(Error::encode)?; frontend::describe(b'S', name, buf).map_err(Error::encode)?;
frontend::sync(buf); frontend::sync(buf);
Ok(buf.split().freeze()) Ok(buf.split().freeze())
}) })

2
tokio-postgres/src/transaction.rs
View File

@ -201,7 +201,7 @@ impl<'a> Transaction<'a> {
I: IntoIterator<Item = P>, I: IntoIterator<Item = P>,
I::IntoIter: ExactSizeIterator, I::IntoIter: ExactSizeIterator,
{ {
let statement = statement.__convert().into_statement(&self.client).await?; let statement = statement.__convert().into_statement(self.client).await?;
bind::bind(self.client.inner(), statement, params).await bind::bind(self.client.inner(), statement, params).await
} }