<?php
$nonauth = true;
require_once("config.inc.php");

/**
 * откуда копируем
 */
$sourceConfig = array(
    'adapter' => 'pdo_mysql',
    'params' => array(
        'host'      => 'localhost',
        'dbname'    => 'default_crm',
        'username'  => '',
        'password'  => '',
        'driver_options' => array(
            1002 => 'SET NAMES CP1251'
        ),
        'charset'   => 'cp1251',
        'debug'     => true
    )
);
/**
 * куда копируем
 */
$destConfig = array(
    'adapter' => 'pdo_mysql',
    'params' => array(
        'host'      => '',
        'dbname'    => 'default_crm',
        'username'  => '',
        'password'  => '',
        'driver_options' => array(
            1002 => 'SET NAMES CP1251'
        ),
        'charset'   => 'cp1251',
        'debug'     => true
    )
);
$doSync = true;
\DbFactory::addConnection($sourceConfig, 'source');
\DbFactory::addConnection($destConfig, 'dest');
$sourceDb = \DbFactory::getConnection('source');
$destDb   = \DbFactory::getConnection('dest');
$offset = 0;
$limit = 100;

while($doSync) {
    $users = $sourceDb->q_assoc("SELECT firstname, man_id FROM managers LIMIT " . $offset . ", " . $limit);
    if(!empty($users)) {
        foreach($users as $usr) {
            $destDb->q_create_update('managers', array(
                'firstname' => $usr['firstname']
            ), sprintf("man_id = '%d'", $usr['man_id']));
        }
    } else {
        $doSync = false;
    }
    $offset += $limit;
    echo "synced " . $offset . " records" . PHP_EOL;
}
print 'Done!';