README

Lumen 5.7.x 数据库查询构建器的 Cassandra 支持

目录

• 先决条件

• 安装

• 查询构建器

• 模式

• 扩展

• 示例

先决条件

• Datastax PHP Driver for Apache Cassandra (https://github.com/datastax/php-driver)
• PHP 7.*

安装

使用 composer

composer require roi-up-agency/lumen-cassandra

在 bootstrap/app.php 文件的 "注册服务提供者" 中添加以下行

$app->register(RoiupAgency\LumenCassandra\CassandraServiceProvider::class);

在 .env 文件中包含以下填充数据

DB_CONNECTION=cassandra
DB_HOST=
DB_PORT=9042
DB_KEYSPACE=mykeyspace
DB_USERNAME=
DB_PASSWORD=
DB_AUTH_TYPE= empty or userCredentials

认证

您可以使用 Laravel 的原生认证功能用于 Cassandra，确保您的 config/auth.php 看起来像

    'providers' => [
    // 'users' => [
    //     'driver' => 'eloquent',
    //     'model' => App\User::class,
    // ],
    'users' => [
        'driver' => 'database',
        'table' => 'users',
    ],
        ],

支持的 CQL 数据类型

text('a')

bigint('b')

blob('c')

boolean('d')

counter('e')

decimal('f')

double('g')

float('h')

frozen('i')

inet('j')

nt('k')

listCollection('l', 'text')

mapCollection('m', 'timestamp', 'text')

setCollection('n', 'int')

timestamp('o')

timeuuid('p')

tuple('q', 'int', 'text', 'timestamp')

uuid('r')

varchar('s')

varint('t')

ascii('u')

主键

primary(['a', 'b'])

查询构建器

数据库驱动程序直接插入原始查询构建器。当使用 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();

Truncate

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

过滤集合集、列表或映射

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

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

在 索引 venues 映射的集合键 后，您可以按映射键进行过滤。

$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')->insert(['emp_id' => 11, 'emp_city' => '{"kochi", "tvm", "kollam"}', 'emp_name' => 'Christy', 'emp_phone' => 12345676890, 'emp_sal' => 500]);

更新

要更新模型，您可以检索它，更改一个属性，并使用 update 方法。

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

更新集合集、列表和映射

一行更新集合。方法如下：

updateCollection(collection_type, column_name, operator, value);

Collection_type可以是集合、列表或映射中的任何一种。

Column_name是要更新的列的名称。

Operator是+或-，+表示将值添加到集合中，-表示从集合中删除值。

Value对于映射类型可以是关联数组，对于列表和集合类型可以是字符串/数字数组。

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();

删除

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

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

我们还可以使用deleteColumn方法通过表中的列进行删除操作

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