Conectividad de aplicaciones con Cassandra

En este artículo, aprenderemos el acceso básico a Cassandra con código, cómo configurar el entorno de desarrollo y cómo usar el código para realizar declaraciones CQL.

En caso de alta disponibilidad y escalabilidad, Cassandra es siempre la mejor opción para conectar su aplicación con la base de datos Cassandra.
echemos un vistazo.

Figura: Conectividad de la aplicación con Cassandra

Para conectarse con cassandra hay muchos Driver disponibles. pocos se enumeran a continuación.

• Java
• Python
• Node.js
• C#

En el lenguaje de programación para conectar la aplicación con la base de datos hay un patrón de programación.
Tres sencillos pasos son los siguientes:

1. Crear una conexión (que se llama Sesión)
2. Utilice la sesión para ejecutar la consulta.
3. Asegúrese de cerrar la conexión/sesión.

Entendamos con el ejemplo uno por uno.

En el lenguaje de programación Java para conectar la aplicación con la base de datos Cassandra utilizando la nube, se utilizaron los siguientes pasos:

• Paso 1:
  Para crear la sesión usó el siguiente código Java.

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

• Paso 2:
  Para ejecutar el CQL usó el siguiente código Java.

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

• Paso 3:
  Para cerrar la sesión usó el siguiente código Java.

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

En el lenguaje de programación Python para conectar la aplicación con Cassandra Database usando la nube, se utilizaron los siguientes pasos:

• Paso 1:
  para crear la sesión, utilizó el siguiente código de Python.

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

• Paso 2:
  Para ejecutar el CQL usó el siguiente código Pyhton.

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

• Paso 3:
  para cerrar la sesión, utilizó el siguiente código de Python.

  session.shutdown()