v1.3.0

Author: ethan

.gitignore

@@ -0,0 +1,4 @@
+.DS_Store
+/vendor
+/.idea
+/composer.lock

README.md

@@ -0,0 +1,45 @@
+# [Database](http://pfinal.cn)
+
+数据库操作类
+
+PHP交流 QQ 群：`16455997`
+
+环境要求：PHP >= 5.3
+
+使用 [composer](https://getcomposer.org/)
+
+  ```shell
+  composer require "pfinal/database"
+  ```
+
+  ```php
+<?php
+
+    require __DIR__ . '/../vendor/autoload.php';
+
+    $config = array(
+        'dsn' => 'mysql:host=localhost;dbname=test',
+        'username' => 'root',
+        'password' => '',
+        'charset' => 'utf8',
+        'tablePrefix' => 'db_',
+    );
+    
+    $db = new \PFinal\Database\Builder($config);
+    
+    $id = $db->table('user')->insertGetId(['username' => 'Jack', 'email' => 'jack@gmail.com']);
+    
+    echo $id;
+    
+  ```
+如果你的项目未使用Composer,请使用下面的方式做类自动加载
+
+```php
+<?php
+
+    include "./src/ClassLoader.php";
+    
+    $loader = new \PFinal\Database\ClassLoader();
+    $loader->register();
+        
+```

composer.json

@@ -0,0 +1,22 @@
+{
+  "name": "pfinal/database",
+  "description": "PHP MySQL database wrapper, extends PDO and PDOStatement",
+  "license": "MIT",
+  "homepage": "http://www.pfinal.cn",
+  "authors": [
+    {
+      "name": "Zou Yiliang"
+    }
+  ],
+  "require": {
+    "php": ">=5.3"
+  },
+  "require-dev": {
+    "phpunit/phpunit": "^5.4"
+  },
+  "autoload": {
+    "psr-4": {
+      "PFinal\\Database\\": "src/"
+    }
+  }
+}

phpunit.xml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         bootstrap="./tests/autoload.php"
+         colors="true"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         processIsolation="false"
+         stopOnFailure="false"
+         syntaxCheck="false">
+    <testsuites>
+        <testsuite name="Application Test Suite">
+            <directory>./tests/</directory>
+        </testsuite>
+    </testsuites>
+</phpunit>

src/ActiveRecord.php

@@ -0,0 +1,95 @@
+<?php
+
+namespace PFinal\Database;
+
+class ActiveRecord extends Builder
+{
+    public function __construct(array $config = array())
+    {
+        parent::__construct($config);
+
+        if (static::$modelStorage === null) {
+            static::$modelStorage = new \SplObjectStorage();
+        }
+        $this->table(static::tableName());
+    }
+
+    public static function tableName()
+    {
+        $name = get_called_class();
+
+        //去掉namespace
+        $name = rtrim(str_replace('\\', '/', $name), '/\\');
+        if (($pos = mb_strrpos($name, '/')) !== false) {
+            $name = mb_substr($name, $pos + 1);
+        }
+
+        //大写转为下划线风格
+        return trim(strtolower(preg_replace('/[A-Z]/', '_\0', $name)), '_');
+    }
+
+    /**
+     * @param Connection $db
+     * @return static
+     */
+    public static function find($db)
+    {
+        $model = new static;
+        return $model->setConnection($db)->asEntity(get_called_class());
+    }
+
+    public function one()
+    {
+        return parent::findOne();
+    }
+
+    public function all()
+    {
+        return parent::findAll();
+    }
+
+    /**
+     * @var \SplObjectStorage
+     */
+    protected static $modelStorage = null;
+
+    public function findAllBySql($sql = '', $params = array(), $fetchClass = null)
+    {
+        if ($fetchClass === null) {
+            return parent::findAllBySql($sql, $params, $fetchClass);
+        } else {
+
+            $models = parent::findAllBySql($sql, $params, $fetchClass);
+
+            array_walk($models, function (&$model) {
+                static::$modelStorage->attach($model, serialize((array)$model));
+            });
+
+            return $models;
+        }
+    }
+
+    public function isNewRecord()
+    {
+        return !static::$modelStorage->contains($this);
+    }
+
+    /**
+     * @return bool
+     */
+    public function save()
+    {
+        if ($this->isNewRecord()) {
+            if (($id = $this->insertGetId((array)$this)) > 0) {
+                $this->id = $id;//todo pk
+                return true;
+            }
+            return false;
+        } else {
+
+            $pk = static::$modelStorage->offsetGet($this);
+
+            return 1 == $this->where('id=?', array($pk))->update((array)$this);//todo pk
+        }
+    }
+}