単純な ORM クラス-php手册-php.cn

興味のある友人にいくつかのアイデアを提供するために、私は自分で簡単な ORM クラスを作成しました。
興味のある友人にいくつかのアイデアを提供するために、私は自分で簡単な ORM クラスを作成しました。 TPさんのアイデアを少し拝借させていただきました。 <?php /** * 著者: ニックバイ *createTime: 2016/11/28 0028 4:00 pm */ MyOrm クラスは ArrayAccess を実装します { パブリック $host = '127.0.0.1' //データベースアドレス ; Public $dbname = 'test' //データベース名 ; Public $user = 'root' //データベースユーザー名 ; Public $pwd = 'root' //データベースパスワード ; パブリック $port = '3306' //データベースポート ; Public $charset = 'utf8' //データベースエンコーディング ; private $conn = null; //データベースリンクリソース Private $alias = [] //グローバルステートメントパラメータを記録します ; Private $sql // 最後の SQL を保存します パブリック関数 __construct() { if( is_null( $this->conn )){ $dsn = "mysql:host=$this->host;dbname=$this->dbname;charset=$this->charset;port=$this->port"; $this->conn = 新しい PDO( $dsn, $this->user, $this->pwd); } } //フィールドステートメント パブリック関数フィールド($field) { If (! Is_string ($ フィールド)) { throw newException("フィールドステートメントのパラメータは文字列である必要があります"); } $this->alias['field'] = $field; $これを返します } //テーブルステートメント パブリック関数テーブル($table) { If (! Is_string ($ テーブル)) { throw newException("テーブルステートメントのパラメータは文字列である必要があります"); } $this->alias['table'] = $table; $これを返します } //where ステートメント パブリック関数 where($where) { $this->alias['where'] = ''; もし（ foreach( $where as $key=>$vo ){ $this->alias['where'] .= " `$key`" . '; } $this->alias['where'] = rtrim( $this->alias['where'], 'and ' ); }else if( is_string( $where )){ $this->alias['where'] = $where; }その他{ throw newException("where ステートメントのパラメータは配列または文字列である必要があります"); } $これを返します } // 制限ステートメント 公開機能制限($limit) { $this->alias['limit'] = ''; if( is_numeric( $limit )){ $this->alias['limit'] = '0,' . }else if( is_string( $limit )){ $this->alias['limit'] = $limit; }その他{ throw newException("limit ステートメントのパラメータは数値または文字列である必要があります"); } $これを返します } //注文明細書 パブリック関数オーダー($order) { もし（ throw newException("順序ステートメントのパラメータは文字列である必要があります"); } $this->alias['order'] = $order; $これを返します } //グループステートメント パブリック関数グループ($group) { If (! Is_string ($ Group)) { throw newException("グループステートメントのパラメータは文字列である必要があります"); } $this->alias['group'] = $group; $これを返します } //クエリSQL文を解析します パブリック関数 ParseSelectSql() { $this->sql = 'select *'; If( !empty( $this->alias['field'] ) ){ $this->sql = str_replace( '*', $this->alias['field'], $this->sql ); } If (Empty ($ this- & gt; alias ['table'])) { throw newException("テーブル句を使用してクエリテーブルを設定してください"); }その他{ $this->sql .= ' from ' . $this->alias['table']; } If( !empty( $this->alias['where'] ) ){ $this->sql .= ' where ' . $this->alias['where']; } $this->sql .= ' グループ化 ' $this->alias['group']; } if( !empty( $this->alias['order'] ) ){ $this->sql .= ' order by ' 。 $this->alias['order']; } if( !empty( $this->alias['limit'] ) ){ $this->sql .= ' 制限 ' 。 $this->エイリアス['制限']; } } // 解析追加sql语句 パブリック関数ParseAddSql() { $this->sql = '挿入 '; if( empty( $this->alias['table'] ) ){ throw new Exception("句请用table子设置追加表"); }その他{ $this->sql .= $this->alias['table'] 。 ' セット '; } return $this->sql; } //解析更新sql语句 パブリック関数ParseUpdateSql() { $this->sql = '更新 '; if( empty( $this->alias['table'] ) ){ throw new Exception("句请用table子设置修改表"); }その他{ $this->sql .= $this->alias['table'] 。 ' セット '; } if( empty( $this->alias['where'] ) ){ throw new Exception("更新语句必须有where子句指定条件"); } return $this->sql; } // 解析删除句sql语 パブリック関数ParseDeleteSql() { $this->sql = '削除元 '; if( empty( $this->alias['table'] ) ){ throw new Exception("句请用table子设置删除表"); }その他{ $this->sql .= $this->alias['table']; } if( empty( $this->alias['where'] ) ){ throw new Exception("句删除语必须有where子句指定条件"); } $this->sql .= ' where ' 。 $this->alias['where']; return $this->sql; } //查询语句 パブリック関数 select() { $this->ParseSelectSql(); $row = $this->conn->query( $this->sql )->fetchAll( PDO::FETCH_ASSOC ); $result = []; foreach( $row as $key=>$vo ){ $arrObj = clone $this // このオブジェクトの汚染を防ぐために現在のオブジェクトを複製します $arrObj->data = $vo; $result[$key] = $arrObj; unset($arrObj); } $ の結果を返します。 } // 1 つの項目をクエリします パブリック関数 find() { $this->ParseSelectSql(); $row = $this->conn->query( $this->sql )->fetch( PDO::FETCH_ASSOC ); $arrObj = clone $this // このオブジェクトの汚染を防ぐために現在のオブジェクトのクローンを作成します $arrObj->data = $row; $result = $arrObj; unset($arrObj); $ の結果を返します。 } //データを追加します パブリック関数 add($data) { If (! Is_array ($ data)) { 新しい例外をスローする（「データの追加メソッドのパラメータは配列である必要があります」）; } $this->ParseAddSql(); foreach( $data as $key=>$vo ){ $this->sql .= " `{$key}` = '" . } $this->conn->exec( rtrim( $this->sql, ',' )); return $this->conn->lastInsertId(); } //ステートメントを更新します パブリック関数の更新($data) { If (! Is_array ($ data)) { throw newException("更新データ更新メソッドのパラメータは配列である必要があります"); } $this->ParseUpdateSql(); foreach( $data as $key=>$vo ){ $this->sql .= " `{$key}` = '" . } $this->sql = rtrim( $this->sql, ',' ) ' where ' . $this->alias['where']; return $this->conn->exec( $this->sql ); } // ステートメントを削除します パブリック関数 delete() { $this->ParseDeleteSql(); return $this->conn->exec( $this->sql ); } //获取查询データ パブリック関数 getData() { $this->データを返す; } //最後に実行した SQL 句を取得します パブリック関数 getLastSql() { return $this->sql; } パブリック関数__get($name) { return $this->getData()[$name]; } public function offsetExists($offset) { if( !isset( $this->getData()[$offset] ) ){ NULL を返します; } } パブリック関数offsetGet($offset) { return $this->getData()[$offset]; } パブリック関数offsetSet($offset, $value) { return $this->data[$offset] = $value; } パブリック関数offsetUnset($offset) { unset( $this->data[$offset] ); } }你可用：$orm = new MyOrm(); //查询语句 $res = $orm->table('user')->order('id desc')->select(); $res = $orm->table('user')->where("name='test'")->order('id desc')->select(); $res = $orm->table('user')->where(['id' => 1])->order('id desc')->find(); $res = $orm->table('user')->where("age > 20")->group('group by name')->order('id desc')->制限(2)->select(); $res = $orm->table('user')->where("age > 20")->group('group by name')->order('id desc')-> limit('2,2')->select(); //この処理データは可能です foreach( $res as $key=>$vo ){ echo $vo->name 。 ' '; } //こんなことしてもいいよ foreach( $res as $key=>$vo ){ echo $vo['name'] 。 ' '; } //これも可 foreach( $res as $key=>$vo ){ print_r( $vo->getData() ) 。 ' '; } // データを追加 $data = [ 「名前」 => 「テスト1」、 「年齢」=> 20、 「パスワード」 => '21232f297a57a5a743894a0e4a801fc3', 「塩」 => 「ドメイン」 ]; $res = $orm->table('user')->add( $data ); //データを更新します $res = $orm->table('user')->where(['id' => 4])->update( ['name' => 'sdfdsfdsd', 'salt' =&gt ; 「111」] ); //删除データ $res = $orm->table('user')->where(['id' => 7, 'id' => 6])->delete(); // 取得句実行の SQL 语 echo $orm->getLastSql(); var_dump($res);