Rust写入数据库的程序

Question

Rust和设备交互通讯，将设备的数据写入数据库里面

use serialport::{DataBits, Parity, StopBits, SerialPortSettings, Error};
use rusqlite::{params, Connection, Result};
use std::io::prelude::*;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 连接到数据库
    let conn = Connection::open("data.db")?;
    conn.execute(
        "CREATE TABLE IF NOT EXISTS device_data (
            id INTEGER PRIMARY KEY,
            data TEXT
        )",
        params![],
    )?;

    // 配置串口参数
    let mut settings = SerialPortSettings::default();
    settings.baud_rate = 9600;
    settings.data_bits = DataBits::Eight;
    settings.parity = Parity::None;
    settings.stop_bits = StopBits::One;

    // 打开串口
    let port = serialport::open("/dev/ttyUSB0")?;
    port.set_timeout(std::time::Duration::from_millis(1000))?;
    port.configure(&settings)?;

    // 读取设备数据并写入数据库
    let mut buffer: Vec<u8> = vec![0; 1024];
    loop {
        match port.read(buffer.as_mut_slice()) {
            Ok(t) => {
                if t > 0 {
                    let data = String::from_utf8_lossy(&buffer[..t]);
                    println!("Received data: {}", data);

                    // 将数据写入数据库
                    conn.execute(
                        "INSERT INTO device_data (data) VALUES (?1)",
                        params![data],
                    )?;
                }
            }
            Err(ref e) if e.kind() == ErrorKind::Timeout => (),
            Err(e) => eprintln!("{:?}", e),
        }
    }
}

Answer 1

use std::result::Result;
use std::boxed::Box;
 
use serialport::{DataBits, Parity, StopBits, SerialPortSettings, Error};
use rusqlite::{Connection, params};
use std::io::prelude::*;
 
fn main() ->
 Result<
(), Box<
dyn std::error::Error>
>
 {// Connect to the databaselet conn = Connection::open("
data.db"
)?;
conn.execute("
CREATE TABLE IF NOT EXISTS device_data (id INTEGER PRIMARY KEY,data TEXT)"
, [])?;
 
    // Configure serial port parameterslet mut settings = SerialPortSettings::default();
settings.baud_rate = 9600;
settings.data_bits = DataBits::Eight;
settings.parity = Parity::None;
settings.stop_bits = StopBits::One;
 
    // Open the serial portlet mut port = serialport::open("
/dev/ttyUSB0"
)?;
port.set_timeout(std::time::Duration::from_millis(1000))?;
port.set_settings(&
settings)?;
 
    let mut buffer = Vec::<
u8>
::with_capacity(1024);
loop {match port.read(buffer.as_mut_slice()) {Ok(t) if t >
 0 =>
 {let data = String::from_utf8_lossy(&
buffer[..t]);
println!("
Received data: {}"
, data);
// Write data to the databaseconn.execute("
INSERT INTO device_data (data) VALUES (?1)"
, params![data])?;
}Err(ref e) if e.kind() == ErrorKind::Timeout =>
 (),Err(e) =>
 eprintln!("
{}"
, e),}}}

在此Rust代码示例中，通过串口与设备进行数据交互，并将接收到的设备数据写入到SQLite数据库中。首先连接到数据库，然后配置串口参数并打开串口。随后循环读取串口数据，将数据转换为字符串并打印出来，然后将数据插入到数据库中。

有问题你别着急，评论留言都可以，看到马上就回复，尽量及时补充齐