与 Cassandra 的应用程序连接

在本文中，我们将通过代码学习基本访问 Cassandra，包括如何设置开发环境以及如何使用代码执行 CQL 语句。

在高可用性和可扩展性的情况下，Cassandra 始终是将您的应用程序与 Cassandra 数据库连接的最佳选择。
我们来看一下。

图 –与 Cassandra 的应用程序连接

要与 cassandra 连接，有许多可用的驱动程序。下面列出了一些。

Java
Python
节点.js
C＃

在将应用程序与数据库连接的编程语言中有一种编程模式。
三个简单的步骤如下：

创建连接(称为会话)
使用会话来执行查询。
请务必关闭连接/会话。

让我们通过例子一一理解。

在Java编程语言中，使用 Cloud 将应用程序与 Cassandra 数据库连接起来，使用了以下步骤：

步骤1：
使用以下Java代码创建会话。

try (DseSession session = DseSession.builder()
            .withCloudSecureConnectBundle
              ("/path/to/secure-connect-database_name.zip")
             // Database Credentials
            .withAuthCredentials("DBUserName", "DBPassword") 
            .build()) {

第2步：
使用以下Java代码执行 CQL。

session.execute(
    SimpleStatement.builder("SELECT password 
                             FROM keyspace-name.Table-name 
                             WHERE email = ?")
        .addPossitionalValues("name@datastax.com")
        .build());

第 3 步：
要关闭会话，请使用以下Java代码。

// Close happens automatically here 
// - otherwise use session.close()
session.close()

在Python编程语言中，使用 Cloud 将应用程序与 Cassandra 数据库连接使用以下步骤：

步骤1：
使用以下Python代码创建会话。

cluster = Cluster(
          cloud = {'secure_connection_bundle' 
                      : '/path / to / secure-connect-database_name.zip'},
          auth_provider = PlainTextAuthProvider('DBUsername', 'DBPassword'))        
           # Database Credentials
         session = cluster.connect()

第2步：
使用以下 Pyhton 代码执行 CQL。

session.execute(("SELECT password 
                  FROM keyspace-name.Table-name 
                  WHERE email = % s, ('name@datastax.com'))

第 3 步：
要关闭会话，请使用以下Python代码。
```
session.shutdown() 
```