The Perl Toolchain Summit needs more sponsors. If your company depends on Perl, please support this very important event.
 / 
App-PipeFilter-0.005
River stage zero No dependents
5 ++
/ App::PipeFilter::MysqlToJson

NAME

App::PipeFilter::MysqlToJson - translate mysql batch output to JSON

VERSION

version 0.005

SYNOPSIS

Here is the mysql2json(1) pipeline filter.

  #!/usr/bin/perl
  use App::PipeFilter::MysqlToJson;
  exit App::PipeFilter::MysqlToJson->new_with_options()->run();

DESCRIPTION

App::PipeFilter::MysqlToJson implements the mysql2json(1) pipeline filter. Please see mysql2json(1) for usage instructions.

This module reads mysql(1) batch output (via the -B option) and produces a single JSON object per MySQL row.

Mysql batch output is produced by the mysql(1) utility's -B flag.

  mysql -B -u user -password -h 10.0.0.5 database \
    -e 'select crontab_id, task_id from crontab' | \
                mysql2json | jsort -k task_id -rn | head -5

Output may look like this:

        {"crontab_id":"102","task_id":"701"}
        {"crontab_id":"101","task_id":"700"}
        {"crontab_id":"100","task_id":"650"}
        {"crontab_id":"8","task_id":"599"}
        {"crontab_id":"14","task_id":"38"}

PUBLIC METHODS

decode_input

App::PipeFilter::MysqlToJson's decode_input() method parses mysql(1) tab-separated rows into Perl data structures. Field names are extracted from the first line of the mysql(1) batch output.

filter_file (before)

mysql(1) batch output is tab-separated values. The first line of output contains column names, which are read by code that runs before filter_file().

SEE ALSO

You may read this module's implementation in its entirety at

  perldoc -m App::PipeFilter::MysqlToJson

App::PipeFilter::MysqlToJson subclasses App::PipeFilter::Generic. It consumes App::PipeFilter::Role::Reader::LineByLine, App::PipeFilter::Role::Output::Json and App::PipeFilter::Role::Transform::None

App::PipeFilter has top-level documentation including a table of contents for all the libraries and utilities included in the project.

BUGS

https://rt.cpan.org/Public/Dist/Display.html?Name=App-PipeFilter

TODO

App::PipeFilter::MysqlToJson uses App::PipeFilter::Role::Reader::LineByLine for simplicity. It could use App::PipeFilter::Role::Reader::Sysread to be significantly faster.

REPOSITORY

https://github.com/rcaputo/app-pipefilter

COPYRIGHT AND LICENSE

App::PipeFilter::MysqlToJson is Copyright 2011 by Rocco Caputo. All rights are reserved. App::PipeFilter::MysqlToJson is released under the same terms as Perl itself.