โปรเจ็ค recordset ใช้งานฐานข้อมูลด้วย Recordset

<?php
/* settings/database.php */
return array(
    'mysql' => array(
        'dbdriver' => 'mysql',
        'username' => 'plus',
        'password' => '1234',
        'dbname' => 'gcms_plus'
    ),
    'tables' => array(
    )
);

<?php
/*
 * @filesource index/models/world.php
 * @link http://www.kotchasan.com/
 * @copyright 2016 Goragod.com
 * @license http://www.kotchasan.com/license/
 */

namespace Index\World;

/**
 * คลาสสำหรับเชื่อมต่อกับฐานข้อมูลของ GCMS
 *
 * @author Goragod Wiriya <admin@goragod.com>
 *
 * @since 1.0
 */
class Model extends \Kotchasan\Orm\Field
{
    /**
     * ชื่อตาราง
     *
     * @var string
     */
    protected $table = 'world';
}

<?php
/*
 * @filesource index/controllers/index.php
 * @link http://www.kotchasan.com/
 * @copyright 2016 Goragod.com
 * @license http://www.kotchasan.com/license/
 */

namespace Index\Index;

use \Kotchasan\Http\Request;
use \Index\World\Model as World;
use \Kotchasan\Date;
use \Kotchasan\Orm\Recordset;

/**
 * default Controller
 *
 * @author Goragod Wiriya <admin@goragod.com>
 *
 * @since 1.0
 */
class Controller extends \Kotchasan\Controller
{

    /**
     * แสดงผล
     *
     * @param Request $request
     */
    public function index(Request $request)
    {
        // อ่านรายชื่อฟิลด์ของตาราง
        $rs = Recordset::create('Index\World\Model');
        $fields = $rs->getFields();
        echo implode(', ', array_keys($fields)).'<br>';
        // ลบข้อมูลทั้งตาราง
        $rs->emptyTable();
        // insert new record
        for ($i = 0; $i < 10000; $i++) {
            $query = World::create();
            $query->updated_at = Date::mktimeToSqlDateTime();
            $query->save();
        }
        // อัปเดททุก record
        $rs->updateAll(array('created_at' => Date::mktimeToSqlDateTime()));
        // อ่านจำนวนข้อมูลทั้งหมดในตาราง
        echo 'All '.$rs->count().' records.<br>';
        // สุ่ม record มาแก้ไข
        for ($i = 0; $i < 5; $i++) {
            $rnd = rand(1, 10000);
            $world = $rs->find($rnd);
            $world->name = 'Hello World!';
            $world->save();
        }
        // query รายการที่มีการแก้ไข
        $rs->where(array('name', '!=', ''));
        // อ่านจำนวนข้อมูลที่พบ
        echo 'Found '.$rs->count().' records.<br>';
        // แสดงผลรายการที่พบ
        foreach ($rs->all('id', 'name') as $item) {
            echo $item->id.'='.$item->name.'<br>';
            // ลบรายการที่กำลังแสดงผล
            $item->delete();
        }
        // อ่านรายชื่อฟิลด์ของ query
        $fields = $rs->getFields();
        echo implode(', ', array_keys($fields)).'<br>';
        // อ่านจำนวนข้อมูลที่เหลือ
        echo 'Remain '.Recordset::create('Index\World\Model')->count().' records.<br>';
    }
}

$rs = Recordset::create('Index\World\Model');

$fields = $rs->getFields();
echo implode(', ', array_keys($fields)).'<br>';

$rs->truncate();

for ($i = 0; $i < 10000; $i++) {
    // สร้างรายการใหม่
    $query = World::create();
    // กำหนด updated_at เป็นวันที่ปัจจุบัน
    $query->updated_at = Date::mktimeToSqlDateTime();
    // บันทึกรายการใหม่ลงฐานข้อมูล
    $query->save();
}

$rs->updateAll(array('created_at' => Date::mktimeToSqlDateTime()));

echo 'All '.$rs->count().' records.<br>';

for ($i = 0; $i < 5; $i++) {
    // สุ่มตัวเลข 1 ถึง 10000
    $rnd = rand(1, 10000);
    // ค้นหาข้อมูลที่ id = $rnd
    $world = $rs->find($rnd);
    // แก้ไขฟิลด์ name ของรายการที่เจอ
    $world->name = 'Hello World!';
    // บันทึกลงในฐานข้อมูล
    $world->save();
}

$rs->where(array('name', '!=', ''));
echo 'Found '.$rs->count().' records.<br>';
// เลือกรายการที่พบออกมา เฉพาะฟิลด์ id และ name เท่านั้น
foreach ($rs->all('id', 'name') as $item) {
    // แสดงผลรายการที่พบ
    echo $item->id.'='.$item->name.'<br>';
    // ลบรายการที่กำลังแสดงผลออกจากฐานข้อมูล
    $item->delete();
}

$fields = $rs->getFields();
echo implode(', ', array_keys($fields)).'<br>';

echo 'Remain '.Recordset::create('Index\World\Model')->count().' records.<br>';