如何使用DBIx::Class执行原生/任意SQL？含事务内存储过程调用

完全理解你的需求——有时候复杂的查询或者存储过程确实没法用DBIC的ORM语法来表达，同时又不想放弃DBIC的事务管理和其他功能，这时候直接调用原生SQL是非常合理的选择。下面分享两种常用的方法，都能保证和DBIC的事务上下文一致：

方法1：用dbh_do直接操作DBI句柄 #

DBIC提供了dbh_do方法，它会帮你拿到当前连接的DBI句柄，而且这个操作会完全继承当前的事务状态——也就是说，如果你的代码已经在DBIC的事务块（比如txn_do）里，原生SQL的执行会和其他DBIC操作在同一个事务里，完美解决你的问题。

示例代码（以调用存储过程为例）：

# 可以用任意结果集，或者直接用schema对象
my $schema = Your::Schema->connect(...);

# 假设你在一个事务里执行操作
$schema->txn_do(sub {
    # 先执行一些DBIC的ORM操作
    $schema->resultset('User')->create({ name => 'Alice' });

    # 调用存储过程，用dbh_do拿到DBI句柄
    my $proc_results = $schema->resultset('User')->dbh_do(sub {
        my ($rs, $dbh) = @_;

        # 根据你的数据库调整语法：PostgreSQL用select，MySQL用call
        my $sth = $dbh->prepare('select proc_name();');
        $sth->execute();
        
        # 获取存储过程的返回结果，按需处理
        return $sth->fetchall_arrayref();
    });

    # 继续执行其他DBIC操作，所有操作都在同一个事务里
    $schema->resultset('Order')->create({ user_id => 1, amount => 99.99 });
});

如果你的存储过程不需要返回结果，直接用$dbh->do('call proc_name();')（MySQL语法）就可以了。

方法2：用from_sql把原生SQL结果映射为DBIC结果集 #

如果你的存储过程返回的结果结构和某个DBIC结果类（对应数据库表）的字段匹配，可以用from_sql方法把原生SQL的结果转换成DBIC的结果集，这样你就能继续用DBIC的链式调用（比如->filter、->page）来处理结果了：

my $proc_rs = $schema->resultset('User')->from_sql(
    'select id, name from proc_get_active_users(?)',
    [ $status_param ]
);

# 像普通DBIC结果集一样操作
foreach my $user ($proc_rs->all) {
    print $user->name;
}

这个方法适合需要复用DBIC结果集功能的场景，但要保证返回字段和结果类的定义一致。

注意事项 #

• 不同数据库的存储过程调用语法有差异：PostgreSQL常用select proc_name(...)，MySQL用call proc_name(...)，Oracle则有自己的语法，要根据你的数据库调整。
• 所有通过dbh_do或from_sql执行的原生SQL，都会和DBIC的事务绑定——只要你在txn_do块里执行，所有操作要么一起提交，要么一起回滚，不用担心事务不一致的问题。
• 虽然DBIC的设计重心是ORM，但它从来没禁止原生SQL的使用，官方FAQ没覆盖只是因为场景太多，这种用法在实际项目里非常普遍。

内容的提问来源于stack exchange，提问作者Eugen Konkov