README

正在开发新版本，请等待文档更新

一个支持Cassandra的查询构建器，使用原始的Laravel API。这个库扩展了原始的Laravel类，因此它使用完全相同的方法。

安装

确保您已安装Apache Cassandra的DataStax PHP驱动程序。您可以在 datastax 仓库找到安装说明。

注意： datastax php-driver 仅与 php 版本 5.6.*、7.0.* 和 7.1.* 兼容

使用composer安装

composer require shso/laravel-cassandra

并在config/app.php中添加服务提供者

# config/app.php
...
providers: [
    ...,
    ShSo\Lacassa\CassandraServiceProvider::class,
    ...,
],
...

配置

更改config/database.php中的默认数据库连接名称

# config/database.php
'default' => env('DB_CONNECTION', 'cassandra'),

并添加一个新的cassandra连接

# config/database.php
'cassandra' => [
    'driver' => 'cassandra',
    'host' => env('DB_HOST', '127.0.0.1'),
    'port' => env('DB_PORT', 9042),
    'keyspace' => env('DB_DATABASE', 'cassandra_db'),
    'username' => env('DB_USERNAME', ''),
    'password' => env('DB_PASSWORD', ''),
    'page_size' => '5000',
    'consistency' => 'local_one',
    'timeout' => null,
    'connect_timeout' => 5.0,
    'request_timeout' => 12.0,
],

注意： 您可以输入所有节点，例如：

# .env
DB_HOST=192.168.100.140,192.168.100.141,192.168.100.142

注意： 您可以选择以下一致性级别之一：

查询构建器

数据库驱动程序直接连接到原始查询构建器。当使用cassandra连接时，您将能够构建流畅的查询以执行数据库操作。

$emp = DB::table('emp')->get();
$emp = DB::table('emp')->where('emp_name', 'Christy')->first();

如果您没有更改默认数据库连接，您需要在每个查询中指定它。

$emp = DB::connection('cassandra')->table('emp')->get();

示例

检索所有记录

$emp = DB::table('emp')->all();

索引列

CREATE INDEX 在给定的表上为指定的列创建一个新的索引。

DB::table('users')->index(['name']);

选择列

$emp = DB::table('emp')->where('emp_no', '>', 50)->select('emp_name', 'emp_no')->get();
$emp = DB::table('emp')->where('emp_no', '>', 50)->get(['emp_name', 'emp_no']);

WHERE子句

WHERE子句指定要查询的行。在WHERE子句中，使用实际名称引用列，而不是别名。WHERE子句中的列需要满足以下要求之一

分区键定义包括该列。
使用 CREATE INDEX 索引的列。

$emp = DB::table('emp')->where('emp_no', '>', 50)->take(10)->get();

AND语句

$emp = DB::table('emp')->where('emp_no', '>', 50)->where('emp_name', '=', 'Christy')->get();

使用数组中的WHERE IN

$emp = DB::table('emp')->whereIn('emp_no', [12, 17, 21])->get();

ORDER BY

ORDER BY子句只能选择单个列。排序可以是升序或降序，默认为升序，并使用ASC或DESC关键字指定。在ORDER BY子句中，使用实际名称引用列，而不是别名。

$emp = DB::table('emp')->where('emp_name', 'Christy')->orderBy('emp_no', 'desc')->get();

限制

我们可以使用limit()和take()来限制查询。

$emp = DB::table('emp')->where('emp_no', '>', 50)->take(10)->get();
$emp = DB::table('emp')->where('emp_no', '>', 50)->limit(10)->get();

Distinct

Distinct需要一个主键字段来返回不同的值。

$emp = DB::table('emp')->distinct()->get(['emp_id']);

Distinct可以与 where 结合使用

$emp = DB::table('emp')->where('emp_sal', 45000)->distinct()->get(['emp_name']);

Count

$number = DB::table('emp')->count();

Count可以与 where 结合使用

$sal = DB::table('emp')->where('emp_sal', 45000)->count();

截断

$sal = DB::table('emp')->truncate();

过滤集合集、列表或映射

您可以索引集合列，然后使用WHERE子句中的CONTAINS条件过滤特定值的数据。

$emp = DB::table('emp')->where('emp_name', 'contains', 'Christy')->get();

在索引venue映射中的集合键之后，您可以过滤映射键。

$emp = DB::table('emp')->where('todo', 'contains key', '2014-10-02 06:30:00+0000')->get();

原始查询

可以将CQL表达式直接注入到查询中。

$emp = DB::raw('select * from emp');

插入、更新和删除

插入、更新和删除记录的工作方式与原始QB相同。

插入

DB::table('emp')
    ->insertCollection('set', 'phn', [123, 1234, 12345])
    ->insertCollection('map', 'friends', [['John', 'Male'], ['Eli', 'Female']])
    ->insert([
        'emp_id' => 11,
        'emp_name' => 'Christy',
        'emp_phone' => 12345676890,
        'emp_sal' => 500
    ]);

更新

要更新模型，您可能需要检索它，更改一个属性，然后使用更新方法。

DB::table('emp')
    ->where('emp_id', 11)
    ->update([
        'emp_city' => 'kochi',
        'emp_name' => 'Christy jos',
        'emp_phone' =>  123456789
    ]);

更新集合集、列表和映射

在一行中更新集合。方法将是

updateCollection(collection_type, column_name, operator, value);

Collection_type 是 set、list 或 map 中的任何一种。

Column_name 是要更新的列的名称。

操作符是 + 或 -，+ 用于向集合中添加值，- 用于从集合中删除值。

值可以是关联数组（用于映射类型），也可以是字符串/数字数组（用于列表和集合类型）。

DB::table('users')->where('id', 1)
    ->updateCollection('set', 'phn', '+', [123, 1234,12345])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('set', 'phn', '-', [123])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('list', 'hobbies', '+', ['reading', 'cooking', 'cycling'])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('set', 'phn', '+', [123, 1234,12345])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('set', 'phn', '-', [123])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('list', 'hobbies', '+', ['reading', 'cooking', 'cycling'])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('list', 'hobbies', '-', ['cooking'])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('map', 'friends', '+', [['John', 'Male'], ['Rex', 'Male']])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('map', 'friends', '-', ['John'])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('map', 'friends', '+', [['John', 'Male'], ['Rex', 'Male']])->update();

DB::table('users')->where('id', 1)
    ->updateCollection('map', 'friends', '-', ['John'])->update();

删除

要删除模型，只需在实例上调用删除方法。我们可以通过使用deleteRow方法来删除表中的行。

$emp = DB::table('emp')->where('emp_city', 'Kochi')->deleteRow();

我们还可以使用deleteColumn方法通过列来执行删除操作。

$emp = DB::table('emp')->where('emp_id', 3)->deleteColumn();

测试

为了测试，运行以下命令一次。

$ php ./prepare_db.php

这将创建一个名为testing的键空间、一个名为users的表、两个名为users_by_username和users_by_email的物化视图、另一个名为posts的表和一个名为posts_by_month的物化视图。您可以在prepare_db.php文件中查看完整的模式。

然后运行phpunit。

# `pwd` = <project root>
$ ./vendor/bin/phpunit tests

aledefreitas / cassandra-laravel

维护者

详细信息