Cassandra 简明教程
Cassandra - Create Data
Creating Data in a Table
您可以使用命令 INSERT 将数据插入表中行的列。以下是创建表中数据的语法。
INSERT INTO <tablename>
(<column1 name>, <column2 name>....)
VALUES (<value1>, <value2>....)
USING <option>
Example
让我们假设有一个名为 emp 的表,其中包含列 (emp_id, emp_name, emp_city, emp_phone, emp_sal),并且必须将以下数据插入到 emp 表。
emp_id |
emp_name |
emp_city |
emp_phone |
emp_sal |
1 |
ram |
Hyderabad |
9848022338 |
50000 |
2 |
robin |
Hyderabad |
9848022339 |
40000 |
3 |
rahman |
Chennai |
9848022330 |
45000 |
使用下面给出的命令用所需的数据填充表。
cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
emp_phone, emp_sal) VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);
cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
emp_phone, emp_sal) VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);
cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
emp_phone, emp_sal) VALUES(3,'rahman', 'Chennai', 9848022330, 45000);
Verification
插入数据后,使用 SELECT 语句验证数据是否已插入。如果你使用 SELECT 语句验证 emp 表,它将向你提供以下输出。
cqlsh:tutorialspoint> SELECT * FROM emp;
emp_id | emp_city | emp_name | emp_phone | emp_sal
--------+-----------+----------+------------+---------
1 | Hyderabad | ram | 9848022338 | 50000
2 | Hyderabad | robin | 9848022339 | 40000
3 | Chennai | rahman | 9848022330 | 45000
(3 rows)
这里你可以观察到这个表已经填充了我们插入的数据。
Creating Data using Java API
你可以使用 Session 类的 execute() 方法在表中创建数据。按照下面给出的步骤,使用 Java API 在表中创建数据。
Step1: Create a Cluster Object
如以下所示,创建 com.datastax.driver.core 包的 Cluster.builder 类的实例。
//Creating Cluster.Builder object
Cluster.Builder builder1 = Cluster.builder();
使用 Cluster.Builder 对象的 addContactPoint() 方法添加一个联系点(节点的 IP 地址)。此方法会返回 Cluster.Builder 。
//Adding contact point to the Cluster.Builder object
Cluster.Builder builder2 = build.addContactPoint("127.0.0.1");
使用新建的对象,创建一个集群对象。为此,在 Cluster.Builder 类中有一个名为 build() 的方法。以下代码显示如何创建一个集群对象。
//Building a cluster
Cluster cluster = builder.build();
您可以使用一行代码构建一个群集对象,如下所示。
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Step 2: Create a Session Object
如以下所示,使用 Cluster 类的 connect() 方法创建一个 Session 对象的实例。
Session session = cluster.connect( );
此方法创建一个新会话并对其进行初始化。如果你已经有一个密钥空间,那么你可以通过将 KeySpace 名称以字符串格式传递给此方法,将其设置为现有的密钥空间,如下所示。
Session session = cluster.connect(“ Your keyspace name ” );
这里我们使用名为 tp 的 KeySpace。因此,创建会话对象如下所示。
Session session = cluster.connect(“ tp” );
Step 3: Execute Query
您可以使用 Session 类的 execute() 方法执行 CQL 查询。将查询以字符串格式或 Statement 类对象的形式传递给 execute() 方法。您以字符串格式传递给此方法的任何内容都将在 cqlsh 上执行。
在以下示例中,我们在名为 emp 的表中插入数据。你必须将查询存储在字符串变量中,然后按如下所示将其传递给 execute() 方法。
String query1 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);” ;
String query2 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);” ;
String query3 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
VALUES(3,'rahman', 'Chennai', 9848022330, 45000);” ;
session.execute(query1);
session.execute(query2);
session.execute(query3);
下面给出了使用 Java API 将数据插入到 Cassandra 中的表中的完整程序。
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
public class Create_Data {
public static void main(String args[]){
//queries
String query1 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)"
+ " VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);" ;
String query2 = "INSERT INTO emp (emp_id, emp_name, emp_city,
emp_phone, emp_sal)"
+ " VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);" ;
String query3 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)"
+ " VALUES(3,'rahman', 'Chennai', 9848022330, 45000);" ;
//Creating Cluster object
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
//Creating Session object
Session session = cluster.connect("tp");
//Executing the query
session.execute(query1);
session.execute(query2);
session.execute(query3);
System.out.println("Data created");
}
}
使用类名保存以上的程序,后跟 .java,浏览到它被保存的位置。编译并执行程序,如下所示。
$javac Create_Data.java
$java Create_Data
在正常条件下,它应该产生以下输出 −
Data created