$reader = new \Converter\Reader\PdoReader(
    'mysql:host=localhost;port=3306;dbname=base;charset=utf8',
    'user',
    'pass',
    [\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION],
    'table'
);

如果需要扩展查询适配器，有 setSQL 方法

设置管理器

读取数据后需要将数据转换为实体

$manager = new \Converter\Manager(
    [['reader' => $reader, 'transformer' => \Converter\Reader\Transformer\BaseTransformer::class]],
    [new \Converter\Processor\FileExistProcessor()],
    [['writer' => $writer, 'transformer' => \Converter\Writer\Transformer\BaseTransformer::class]]
);
$manager->manage();