È possibile utilizzare DBIx :: Class con stored procedure anziché con tabelle?

Question

L'accesso alla lettura dal db mi è stato dato tramite procedure memorizzate mssql che restituiscono serie di risultati anziché tabelle o viste. Ma voglio essere in grado di leggere i dati usando ORM.

Ho provato a utilizzare DBIx::Class::ResultSource::View per eseguire la chiamata di procedura (ad esempio EXEC my_stored_proc ?) come una query personalizzata ma questo non ha funzionato perché ha tentato di convertire la chiamata di procedura in un'istruzione select.

Qualcuno ha un altro suggerimento?

Answer 1

No, non c'è modo ragionevole per eseguire una stored procedure nel contesto di DBIx :: Class.

Per quanto posso dire, la cosa più vicina ad una soluzione sta "utilizzando l'ORM" per ottenere un handle di database, che è zuppa debole:

my @results = $schema->storage->dbh_do(sub{ 
     my ($storage, $dbh, @args) = @_; 
     my $sth = $dbh->prepare('call storedProcNameFooBar()'); 
     my @data; 
     $sth->execute(); 
     while(my $row = $sth->fetchrow_hashref){ 
      push @data, $row; 
     } 
     return @data; 
    },()); 

[vedi dettagli a http://metacpan.org/pod/DBIx::Class::Storage::DBI#dbh_do]

... in quanto non ottieni nessuno dei vantaggi di un ORM per il tuo problema.

Answer 2

È possibile utilizzare register_source

package My::Schema::User; 

    use base qw/DBIx::Class/; 

    # ->load_components, ->table, ->add_columns, etc. 

    # Make a new ResultSource based on the User class 
    my $source = __PACKAGE__->result_source_instance(); 
    my $new_source = $source->new($source); 
    $new_source->source_name('UserFriendsComplex'); 

    # Hand in your query as a scalar reference 
    # It will be added as a sub-select after FROM, 
    # so pay attention to the surrounding brackets! 
    $new_source->name(\<<SQL); 
    (SELECT u.* FROM user u 
    INNER JOIN user_friends f ON u.id = f.user_id 
    WHERE f.friend_user_id = ? 
    UNION 
    SELECT u.* FROM user u 
    INNER JOIN user_friends f ON u.id = f.friend_user_id 
    WHERE f.user_id = ?) 
    SQL 

    # Finally, register your new ResultSource with your Schema 
    My::Schema->register_source('UserFriendsComplex' => $new_source); 

Per chiamare con i parametri procedere nel modo seguente

my $friends = [ $schema->resultset('UserFriendsComplex')->search({ 
+}, 
    { 
     bind => [ 12345, 12345 ] 
    } 
) ];