mint/app/redis/upgrade_pali_sent.php

<?php
/*
get user sentence from db
 */
require_once "../path.php";
require_once "../public/_pdo.php";
require_once "../public/function.php";

if (isset($argv[1])) {
    if ($argv[1] == "del") {
        $redis = new redis();
        $r_conn = $redis->connect('127.0.0.1', 6379);
        $keys = 'pali_sent_*';
        $redis->delete($redis->keys($keys));
    }
} else {
    $dns = "" . _FILE_DB_PALI_SENTENCE_;
    $dbh = new PDO($dns, "", "", array(PDO::ATTR_PERSISTENT => true));
    $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

    $query = "SELECT book,paragraph, begin,end ,text FROM pali_sent WHERE 1 ";
    $stmt = $dbh->prepare($query);
    $stmt->execute();
    $redis = new redis();
    $r_conn = $redis->connect('127.0.0.1', 6379);
    $stringSize = 0;
    if ($r_conn) {
        while ($sent = $stmt->fetch(PDO::FETCH_ASSOC)) {
            $stringSize += strlen($sent["text"]);
            if ($stringSize > 50000000) {
                sleep(1);
                $stringSize = 0;
                echo $sent["book"] . "_" . $sent["paragraph"] . "\n";
            }
            $result = $redis->set('pali_sent_' . $sent["book"] . "_" . $sent["paragraph"] . "_" . $sent["begin"] . "_" . $sent["end"], $sent["text"]);
        }
        echo "完成";
    } else {
        echo "连接redis失败";
    }
}