$sth->execute( map { $h->{$_} } @c );
}
-sub insert : Job : Decode(d_json) {
+sub insert : Job : Decode(d_json) : MinProcesses(0) {
my ( $self, $job, $workload ) = @_;
my $table = delete $workload->{_table} || die "no _table";
$self->pg_insert($table => $workload);
}
-sub sql : Job : Encode(e_json) {
+sub sql : Job : Encode(e_json) : MinProcesses(0) {
my ( $self, $job, $workload ) = @_;
my $sth = $self->dbh->prepare($workload);
- my $rows = $sth->execute;
+ my $rows = eval { $sth->execute };
+ return { error => $@ } if $@;
warn "# $rows rows get_username_table $workload\n";