:Bulk::Array;
use Data::Stream::Bulk::DBI;
use Data::Stream::Bulk::Filter;
use File::Temp ();
use JSON 2 ();
use List::AllUtils qw/uniq/;
use Metabase::Fact;
use SQL::Abstract;
use SQL::Translato
,
};
my $json = eval { JSON->new->utf8->encode($fact) };
Carp::confess "Couldn't convert to JSON: $@"
unless $json;
# if ( $self->compressed ) {
# $json = compress($json);
# }
tr
f->dbis->insert($self->_table_name, {
guid => $self->_munge_guid($guid),
fact => $json,
});
$self->dbis->commit;
}
catch {
$self->dbis->rollback;
Carp::confess("E