Struct Connection 

pub struct Connection { /* private fields */ }

An open connection to a MySQL database.

Examples

Load a set of rows from a local PostgreSQL database, and iterate over them.

use spin_sdk::mysql::{Connection, Decode, ParameterValue};

let db = Connection::open("mysql://root:my_password@localhost/mydb")?;

let query_result = db.query(
    "SELECT * FROM users WHERE age < ?",
    &[ParameterValue::Int32(20)]
)?;

let name_index = query_result.columns.iter().position(|c| c.name == "name").unwrap();

for row in &query_result.rows {
    let name = String::decode(&row[name_index])?;
    println!("Found user {name}");
}

Perform an aggregate (scalar) operation over a table. The result set contains a single column, with a single row.

use spin_sdk::mysql::{Connection, Decode};

let db = Connection::open("mysql://root:my_password@localhost/mydb")?;

let query_result = db.query("SELECT COUNT(*) FROM users", &[])?;

assert_eq!(1, query_result.columns.len());
assert_eq!("COUNT(*)", query_result.columns[0].name);
assert_eq!(1, query_result.rows.len());

let count = i64::decode(&query_result.rows[0][0])?;

Delete rows from a MySQL table. This uses Connection::execute() instead of the query method.

use spin_sdk::mysql::{Connection, ParameterValue};

let db = Connection::open("mysql://root:my_password@localhost/mydb")?;

let rows_affected = db.execute(
    "DELETE FROM users WHERE name = ?",
    &[ParameterValue::Str("Baldrick".to_owned())]
)?;

A connection to a MySQL database.

Implementations

impl Connection

pub fn open(address: &str) -> Result<Connection, Error>

Open a connection to the MySQL instance at address.

impl Connection

pub fn query( &self, statement: &str, params: &[ParameterValue], ) -> Result<RowSet, Error>

query the database: select

impl Connection

pub fn execute( &self, statement: &str, params: &[ParameterValue], ) -> Result<(), Error>

execute command to the database: insert, update, delete

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.