Struct SqlRepository 

pub struct SqlRepository<E: Model + ModelExt + Default + Clone + Send + Sync + 'static> { /* private fields */ }

Repository 的 SQL 后端实现。

重写 batch_create/batch_upsert/paginate_sql 为真正 SQL 实现， 复用 QueryBuilder + Connection，区别于 Repository trait 默认实现 （逐条 save / 内存切片）。

泛型约束

• E: Model + ModelExt — 获取表名/列名/列值
• E: Default — 从行数据还原实体（from_value 需 &mut self）
• E: Clone + Send + Sync + 'static — 异步安全

示例

use sz_orm_core::{DbType, Pool};
use sz_orm_sqlx::SqlRepository;
let repo = SqlRepository::<E>::new(pool, DbType::MySQL);
let n = repo.batch_create(&entities).await.unwrap();

Implementations

impl<E: Model + ModelExt + Default + Clone + Send + Sync + 'static> SqlRepository<E>

pub fn new(pool: Pool, dialect: DbType) -> Self

构造 SqlRepository，须传入已初始化的连接池 + 数据库方言。

pub async fn find_all(&self) -> Result<Vec<E>, RepositoryError>

查询所有记录。

pub async fn find_by( &self, conditions: &[WhereCondition], ) -> Result<Vec<E>, RepositoryError>

按条件查询。

pub async fn save(&self, entity: &mut E) -> Result<u64, RepositoryError>

保存（INSERT）。

pub async fn count(&self) -> Result<u64, RepositoryError>

总数。

pub async fn batch_create(&self, entities: &[E]) -> Result<u64, RepositoryError>

v9.5.1 真正多值 INSERT，复用 QueryBuilder::build_batch_insert_with_params。

重写 Repository trait 默认实现（逐条 save），生成 1 条多值 INSERT SQL。

• 空批返回 Ok(0)，不执行 SQL
• 所有值参数化绑定，杜绝 SQL 注入

pub async fn batch_upsert( &self, entities: &[E], conflict_cols: &[&str], update_cols: &[&str], ) -> Result<u64, RepositoryError>

v9.5.1 真正 INSERT ON CONFLICT，复用 QueryBuilder::build_batch_upsert_with_params。

重写 Repository trait 默认实现，生成 1 条 UPSERT SQL。

• conflict_cols：冲突检测列（主键/唯一键）
• update_cols：冲突时更新的列；空切片表示更新所有非冲突列
• 空批返回 Err(InvalidParams)

pub async fn paginate_sql( &self, page: u64, page_size: u64, ) -> Result<PageResult<E>, RepositoryError>

v9.5.1 真正 SQL LIMIT/OFFSET + COUNT，执行 2 条 SQL。

重写 Repository trait 默认实现（内存切片 paginate）。

• page == 0 || page_size == 0 返回 Err(InvalidParams)
• 执行 SELECT ... LIMIT ? OFFSET ? + SELECT COUNT(*) FROM table 两条 SQL