add db component step 1

Author: neatlife

.gitignore

@@ -409,4 +409,5 @@ composer.lock
 #
 # Recommended template: PHP.gitignore
 
-/wpcs/*
+/wpcs/*
+.idea

.idea/misc.xml

@@ -2,7 +2,7 @@
 
 ## 功能
 
-1. [x] 使用symfony的console组建启动swoole的serverr
+1. [x] 使用symfony的console组建启动swoole的server
 2. [x] 使用swoole创建http server
 3. [x] 使用symfofny的event组件传递http事件
 6. [x] 参考laravel的ServiceProvider特性设计组建注册
@@ -12,6 +12,7 @@
 8. [ ] 使用hash算法进行db组建设计，支持分库分表
 9. [ ] 多个包使用composer进行包管理
 10. [ ] psr有规范的组件严格遵守规范
+10. [ ] 分库分表
 
 
 ## 测试

.idea/modules.xml

@@ -15,7 +15,9 @@
         "symfony/console": "^3.4",
         "symfony/event-dispatcher": "^3.4",
         "symfony/dependency-injection": "^3.4",
-        "symfony/http-foundation": "^3.4"
+        "symfony/http-foundation": "^3.4",
+        "ext-pdo": "*",
+        "latitude/latitude": "^2.3"
     },
     "require-dev": {
         "phpunit/phpunit": "^6.0"

.idea/pframework.iml

@@ -7,4 +7,42 @@
     'providers' => [
         pframework\web\WebApplicationProvider::class,
     ],
+    'db' => [
+        'single' => [
+            'host' => '127.0.0.1',
+            'port' => 3306,
+            'db' => 'test',
+            'username' => 'root',
+            'password' => 'root',
+        ],
+        'mutiply' => [
+            'tables' => [
+                'order' => [
+                    'shard' => 10,
+                    'strategy' => pframework\db\strategy\Crc32Strategy::class
+                ],
+                'user' => [
+                    'shard' => 20,
+                    'strategy' => pframework\db\strategy\ModStrategy::class
+                ]
+            ],
+            'strategy' => pframework\db\strategy\ModStrategy::class,
+            'connections' => [
+                [
+                    'host' => '127.0.0.1',
+                    'port' => 3306,
+                    'db' => 'test',
+                    'username' => 'root',
+                    'password' => 'root',
+                ],
+                [
+                    'host' => '127.0.0.1',
+                    'port' => 3306,
+                    'db' => 'test1',
+                    'username' => 'root',
+                    'password' => 'root',
+                ],
+            ],
+        ]
+    ],
 ];

.idea/php.xml

@@ -0,0 +1,35 @@
+<?php
+
+namespace app\provider;
+
+use pframework\AbstractServiceProvider;
+use pframework\db\Connection;
+use pframework\db\MultiplyConnection;
+
+class DbProvider extends AbstractServiceProvider
+{
+    public function boot()
+    {
+        $config = $this->app->getConfig();
+        // 分库
+        if (isset($config['db']['mutiply'])) {
+            $multiplyConnectionsConfig = $config['db']['multiply'];
+            $multiplyConnection = new MultiplyConnection($multiplyConnectionsConfig);
+
+            $multiplyConnection->setDbShardStrategy(new $multiplyConnectionsConfig['strategy']);
+
+            foreach ($multiplyConnectionsConfig['multiply']['table'] as $tableName => $shardTableConfig) {
+                $tableStrategy = new $shardTableConfig['strategy']($shardTableConfig['shard']);
+                $multiplyConnection->addTableShardStrategy($tableName, $tableStrategy);
+            }
+
+            $this->container->set("testShardDb", $multiplyConnection);
+        }
+
+        // 单库
+        if (isset($config['db']['single'])) {
+            $connection = new Connection($config['db']['single']);
+            $this->container->set("testDb", $connection);
+        }
+    }
+}

.idea/vcs.xml

@@ -0,0 +1,24 @@
+<?php
+
+
+namespace pframework\db;
+
+use PDO;
+
+
+class Connection extends PDO implements ConnectionInterface
+{
+    private $config;
+
+    public function __construct($config)
+    {
+        $this->config = $config;
+        parent::__construct();
+    }
+
+    public function table($table)
+    {
+        // TODO: Implement table() method.
+    }
+
+}

README.md

@@ -0,0 +1,10 @@
+<?php
+
+
+namespace pframework\db;
+
+
+interface ConnectionInterface
+{
+    public function table($table);
+}

composer.json

@@ -0,0 +1,61 @@
+<?php
+
+namespace pframework\db;
+
+use pframework\db\strategy\StrategyInterface;
+
+class MultiplyConnection implements ConnectionInterface
+{
+    /**
+     * @var StrategyInterface
+     */
+    private $dbShardStrategy;
+
+    /**
+     * @var StrategyInterface[]
+     */
+    private $tableShardStrategy;
+
+    private $dbShardValue;
+
+    private $tableShardValue;
+
+    private $config;
+
+    public function __construct($config)
+    {
+        $this->config = $config;
+    }
+
+    public function setDbShardStrategy(StrategyInterface $strategy)
+    {
+        $this->dbShardStrategy = $strategy;
+    }
+
+    public function addTableShardStrategy(string $table, StrategyInterface $strategy)
+    {
+        $this->tableShardStrategy[$table] = $strategy;
+    }
+
+    public function setDbShardValue($dbShardValue)
+    {
+        $this->dbShardValue = $dbShardValue;
+    }
+
+    public function setTableShardValue($tableShardValue)
+    {
+        $this->tableShardValue = $tableShardValue;
+    }
+
+    public function table($table)
+    {
+        $shardDbIndex = $this->dbShardStrategy->shardByValue($this->dbShardValue);
+        $shardTable = $this->tableShardStrategy[$table]->shardByValue($this->tableShardValue);
+        return new QueryBuilder($this->getConnection($shardDbIndex), $shardTable);
+    }
+
+    public function getConnection($shardDbIndex)
+    {
+        return new Connection();
+    }
+}

config/app.php

@@ -0,0 +1,28 @@
+<?php
+
+
+namespace pframework\db;
+
+
+class QueryBuilder implements QueryBuilderInterface
+{
+    /**
+     * @var ConnectionInterface $connection
+     */
+    private $connection;
+
+    private $table;
+
+    public function __construct(ConnectionInterface $connection, $table)
+    {
+        $this->connection = $connection;
+        $this->table = $table;
+    }
+
+    public function select($field)
+    {
+        $sql = "SELECT * FROM {$this->table} WHERE {$this->where} LIMIT {$this->limit}";
+
+
+    }
+}

src/app/provider/DbProvider.php

@@ -0,0 +1,10 @@
+<?php
+
+
+namespace pframework\db;
+
+
+interface QueryBuilderInterface
+{
+    public function __construct(ConnectionInterface $connection, $table);
+}

src/pframework/db/Connection.php

@@ -0,0 +1,20 @@
+<?php
+
+
+namespace pframework\db\strategy;
+
+
+class Crc32Strategy implements StrategyInterface
+{
+    private $shardCount;
+
+    public function __construct($shardCount)
+    {
+        $this->shardCount = $shardCount;
+    }
+
+    public function shardByValue($value)
+    {
+        return (sprintf("%u", crc32($value)) >> 16 & 0x7fff) % $this->shardCount;
+    }
+}

src/pframework/db/ConnectionInterface.php

@@ -0,0 +1,21 @@
+<?php
+
+
+namespace pframework\db\strategy;
+
+
+class ModStrategy implements StrategyInterface
+{
+    private $shardCount;
+
+    public function __construct($shardCount)
+    {
+        $this->shardCount = $shardCount;
+    }
+
+    public function shardByValue($value)
+    {
+        return $value % $this->shardCount;
+    }
+
+}

src/pframework/db/MultiplyConnection.php

@@ -0,0 +1,12 @@
+<?php
+
+
+namespace pframework\db\strategy;
+
+
+interface StrategyInterface
+{
+    public function __construct($shardCount);
+
+    public function shardByValue($value);
+}