tbp

TBP

TBPは、中小ウェブサイトを開発するために設計された軽いフレームワークです。コンポーネント指向に焦点を合わせます

データベースインターフェイス

sqlite

sqlite3へのコネクタ。準備されたステートメント（必須）で動作します。トランザクションのサポート。

インストール

PHP拡張ext-sqlite3必要です。 phpinfo()を確認してください。デフォルトでは、 tbp-web-server Docker ImageはSQLiteをサポートしています。

composer.jsonに追加しますrequire

 "ext-sqlite3": "*"

構成

config/my-sqlite.configなどの構成ファイルを作成します

 # TBP/SQLite config file.
# ALL PARAMETERS ARE OPTIONAL!

# Database file name (if not defined, will use 'default.db')
filename=resources/test.db

# Access type
# readOnly=yes

# Encryption key (if not defined, no encryption used)
# encryptionKey=

実装

AbstractSqliteDomainを拡張するドメインを作成し、構成ファイルを渡します。必要なクエリごとに1つのメソッドを追加します。

 class MyDomain extends AbstractSqliteDomain
{
    public function __construct ()
    {
        $ configReader = new Config ( __CONFIG_PATH__ );            // <-- get a config reader, passing your config folder
        $ config = $ configReader -> getConfig ( ' my-sqlite ' );        // <-- read your configuration, passing your config base name
        $ config -> filename =                                     // <-- convert your relative path into absolute path
            __BASE_PATH__ .
            DIRECTORY_SEPARATOR .
            $ config -> filename ;
        parent :: __construct ( $ config );
        $ this -> open ();                                          // <-- open a db connection and let's rock!
    }

    public function addRegister ( $ a , $ b )
    {
        $ sql = " INSERT INTO `MyTableWithAutoInc` (`a`, `b`) VALUES (?, ?) " ;
        $ params = array ( $ a , $ b );
        return self :: insertWithAutoincrement ( $ this -> connection -> command ( $ sql , $ params ));
    }

    public function addAnotherRegister ( $ a , $ b )
    {
        $ sql = " INSERT INTO `MyOtherTable` (`a`, `b`) VALUES (?, ?) " ;
        $ params = array ( $ a , $ b );
        return $ this -> connection -> command ( $ sql , $ params );
    }

    public function getRegisters ( $ b )
    {
        $ sql = " SELECT * FROM `MyTableWithAutoInc` WHERE `b` <= ? " ;
        $ params = array ( $ b );
        return self :: getAll ( $ this -> connection -> select ( $ sql , $ params ));
    }

    public function getRegisterById ( $ id )
    {
        $ sql = " SELECT * FROM `MyTableWithAutoInc` WHERE `MyId` = ? " ;
        $ params = array ( $ id );
        return self :: getSingle ( $ this -> connection -> select ( $ sql , $ params ));
    }
}

使用法

サンプルストレートフォワードコード：

 $ domain = new MyDomain ();
$ results = $ domain -> getRegisters ( 9391 ); // get an array

トランザクションを備えたサンプルコード：

 $ domain = new MyDomain ();
try {
    $ domain -> begin ();
    
    $ lastId = $ domain -> addRegister ( 1 , 2 );
    echo " first query: last inserted id: $ lastId n" ;
    
    $ lastId = $ domain -> addRegister ( 3 , 4 );
    echo " second query: last inserted id: $ lastId n" ;
    
    $ domain -> commit ();
} catch ( Exception $ e ) {
    $ domain -> rollback ();
    echo " ERROR: " . $ e -> getMessage () . "n" ;
}