Struct SqliteItemWriter 

pub struct SqliteItemWriter<'a, O> { /* private fields */ }

Available on crate feature rdbc only.

A writer for inserting items into a SQLite database using SQLx.

This writer provides an implementation of the ItemWriter trait for SQLite operations. It supports batch inserting items into a specified table with the provided columns.

SQLite-Specific Features

• Supports SQLite’s flexible type system
• Handles SQLite’s AUTOINCREMENT for auto-incrementing columns
• Supports SQLite’s INSERT OR REPLACE operations
• Leverages SQLite’s efficient bulk insert capabilities
• Compatible with SQLite’s connection pooling and prepared statements

Examples

use spring_batch_rs::item::rdbc::{RdbcItemWriterBuilder, DatabaseItemBinder};
use spring_batch_rs::core::item::ItemWriter;
use sqlx::{SqlitePool, query_builder::Separated, Sqlite};
use serde::Serialize;

#[derive(Clone, Serialize)]
struct Task {
    id: i32,
    title: String,
    completed: bool,
}

struct TaskBinder;
impl DatabaseItemBinder<Task, Sqlite> for TaskBinder {
    fn bind(&self, item: &Task, mut query_builder: Separated<Sqlite, &str>) {
        let _ = (item, query_builder); // Placeholder to avoid unused warnings
        // In real usage: query_builder.push_bind(item.id);
        // In real usage: query_builder.push_bind(&item.title);
        // In real usage: query_builder.push_bind(item.completed);
    }
}

let pool = SqlitePool::connect("sqlite::memory:").await?;
let binder = TaskBinder;

let writer = RdbcItemWriterBuilder::<Task>::new()
    .sqlite(&pool)
    .table("tasks")
    .add_column("id")
    .add_column("title")
    .add_column("completed")
    .sqlite_binder(&binder)
    .build_sqlite();

let tasks = vec![
    Task { id: 1, title: "Task 1".to_string(), completed: false },
    Task { id: 2, title: "Task 2".to_string(), completed: true },
];

writer.write(&tasks)?;

Trait Implementations

impl<'a, O> Default for SqliteItemWriter<'a, O>

fn default() -> Self

Returns the “default value” for a type.

impl<O: Serialize + Clone> ItemWriter<O> for SqliteItemWriter<'_, O>

fn write(&self, items: &[O]) -> ItemWriterResult

Writes the given items.

fn flush(&self) -> ItemWriterResult

Flushes any buffered data.

fn open(&self) -> ItemWriterResult

Opens the writer.

fn close(&self) -> ItemWriterResult

Closes the writer.