{"id":14097,"date":"2020-03-21T03:56:52","date_gmt":"2020-03-21T03:56:52","guid":{"rendered":"http:\/\/bigdata-ir.com\/?p=1914"},"modified":"2020-03-21T03:56:52","modified_gmt":"2020-03-21T03:56:52","slug":"%d8%a2%d9%85%d9%88%d8%b2%d8%b4-%d8%a7%d8%aa%d8%b5%d8%a7%d9%84-%d8%a8%d9%87-casandra-%d8%a8%d8%a7-java","status":"publish","type":"post","link":"https:\/\/afaghhosting.net\/blog\/%d8%a2%d9%85%d9%88%d8%b2%d8%b4-%d8%a7%d8%aa%d8%b5%d8%a7%d9%84-%d8%a8%d9%87-casandra-%d8%a8%d8%a7-java\/","title":{"rendered":"\u0622\u0645\u0648\u0632\u0634 \u0627\u062a\u0635\u0627\u0644 \u0628\u0647 casandra \u0628\u0627 java"},"content":{"rendered":"
\"\"<\/div>\n

import <\/span>com<\/span>.<\/span>datastax<\/span>.<\/span>driver<\/span>.<\/span>core<\/span>.<\/span>*<\/span>;<\/span><\/p>\n

\/**<\/span><\/p>\n

* this class is use to handel all interaction between application and data base<\/span><\/p>\n

*\/<\/span><\/p>\n

public<\/span> class<\/span> CassandraDAO<\/span> {<\/span><\/p>\n

private<\/span> static<\/span> Cluster <\/span>cluster<\/span>;<\/span><\/p>\n

private<\/span> static<\/span> Session <\/span>session<\/span>;<\/span><\/p>\n

private<\/span> final<\/span> static<\/span> String<\/span> KEYSPACE_NAME<\/span> =<\/span> “example_keyspace”<\/span>;<\/span><\/p>\n

private<\/span> final<\/span> static<\/span> String<\/span> REPLICATION_STRATEGY<\/span> =<\/span> “SimpleStrategy”<\/span>;<\/span><\/p>\n

private<\/span> final<\/span> static<\/span> int<\/span> REPLICATION_FACTOR<\/span> =<\/span> 1<\/span>;<\/span><\/p>\n

private<\/span> final<\/span> static<\/span> String<\/span> TABLE_NAME<\/span> =<\/span> “Employe_table”<\/span>;<\/span><\/p>\n

private<\/span> static<\/span> void<\/span> openCassandra<\/span>(<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

\/\/ Setup a cluster to your local instance of Cassandra<\/span><\/p>\n

cluster<\/span> =<\/span> Cluster<\/span>.<\/span>builder<\/span>(<\/span>)<\/span><\/p>\n

.<\/span>addContactPoint<\/span>(<\/span>“192.168.174.141”<\/span>)<\/span><\/p>\n

.<\/span>withPort<\/span>(<\/span>9042<\/span>)<\/span><\/p>\n

.<\/span>build<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Create a session to communicate with Cassandra<\/span><\/p>\n

session<\/span> =<\/span> cluster<\/span>.<\/span>connect<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>“Cassandra is Connecting…”<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

private<\/span> static<\/span> void<\/span> closeCassandra<\/span>(<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

session<\/span>.<\/span>close<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

cluster<\/span>.<\/span>close<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>“Cassandra is closing… \\n”<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> createKeyspace<\/span> (<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

openCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Create a new Keyspace (database) in Cassandra<\/span><\/p>\n

String<\/span> createkeyspace1<\/span> =<\/span> String<\/span>.<\/span>format<\/span>(<\/span><\/p>\n

“CREATE KEYSPACE IF NOT EXISTS %s WITH replication = “<\/span> +<\/span><\/p>\n

“{‘class’:’%s’,’replication_factor’:%s};”<\/span>,<\/span><\/p>\n

KEYSPACE_NAME<\/span>,<\/span><\/p>\n

REPLICATION_STRATEGY<\/span>,<\/span><\/p>\n

REPLICATION<\/span>_<\/span>FACTOR<\/p>\n

)<\/span>;<\/span><\/p>\n

session<\/span>.<\/span>execute<\/span>(<\/span>createkeyspace1<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>“create Keyspace…”<\/span>)<\/span>;<\/span><\/p>\n

closeCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> createTable<\/span> (<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

openCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Create a new table in our Keyspace<\/span><\/p>\n

String<\/span> createTable<\/span> =<\/span> String<\/span>.<\/span>format<\/span>(<\/span><\/p>\n

“CREATE TABLE IF NOT EXISTS %s.%s “<\/span> +<\/span> “”<\/span> +<\/span><\/p>\n

“(emp_id int, emp_city text, emp_name text, emp_phone text, emp_sal int, “<\/span> +<\/span><\/p>\n

“PRIMARY KEY ((emp_id , emp_city), emp_name)) “<\/span> +<\/span><\/p>\n

“WITH CLUSTERING ORDER BY (emp_name ASC);”<\/span>,<\/span><\/p>\n

KEYSPACE_NAME<\/span>,<\/span><\/p>\n

TABLE<\/span>_<\/span>NAME<\/p>\n

)<\/span>;<\/span><\/p>\n

session<\/span>.<\/span>execute<\/span>(<\/span>createTable<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>“create column family…”<\/span>)<\/span>;<\/span><\/p>\n

closeCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> insertEmploye<\/span>(<\/span>EmployePOJO <\/span>employe<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

openCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Create an insert statement to add a new item to our table<\/span><\/p>\n

PreparedStatement <\/span>insertPrepared<\/span> =<\/span> session<\/span>.<\/span>prepare<\/span>(<\/span>String<\/span>.<\/span>format<\/span>(<\/span><\/p>\n

“INSERT INTO %s.%s (emp_id, emp_city, emp_name, emp_phone, emp_sal) values (?, ?, ?, ?, ?)”<\/span>,<\/span><\/p>\n

KEYSPACE_NAME<\/span>,<\/span><\/p>\n

TABLE<\/span>_<\/span>NAME<\/p>\n

)<\/span>)<\/span>;<\/span><\/p>\n

int<\/span> id<\/span> =<\/span>employe<\/span>.<\/span>getEmploye_id<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

String<\/span> city<\/span>=<\/span> employe<\/span>.<\/span>getEmploye_city<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

String<\/span> name<\/span>=<\/span> employe<\/span>.<\/span>getEmploye_name<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

String<\/span> phone<\/span>=<\/span>employe<\/span>.<\/span>getEmploye_phone<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

int<\/span> sal<\/span>=<\/span>employe<\/span>.<\/span>getEmploye_sal<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Bind the data to the insert statement and execute it<\/span><\/p>\n

BoundStatement <\/span>insertBound<\/span> =<\/span> insertPrepared<\/span>.<\/span>bind<\/span>(<\/span>id<\/span>,<\/span>city<\/span>,<\/span>name<\/span>,<\/span>phone<\/span>,<\/span>sal<\/span>)<\/span>;<\/span><\/p>\n

session<\/span>.<\/span>execute<\/span>(<\/span>insertBound<\/span>)<\/span>;<\/span><\/p>\n

System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>“insert data…”<\/span>)<\/span>;<\/span><\/p>\n

closeCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> getEmploye<\/span>(<\/span>int<\/span> id<\/span>,<\/span> String<\/span> city<\/span>)<\/span> throws<\/span> Exception<\/span>{<\/span><\/p>\n

openCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Create a select statement to retrieve the item we just inserted<\/span><\/p>\n

PreparedStatement <\/span>selectPrepared<\/span> =<\/span> session<\/span>.<\/span>prepare<\/span>(<\/span>String<\/span>.<\/span>format<\/span>(<\/span><\/p>\n

“SELECT emp_id, emp_city, emp_name FROM %s.%s WHERE emp_id = ? and emp_city = ?”<\/span>,<\/span><\/p>\n

KEYSPACE_NAME<\/span>,<\/span><\/p>\n

TABLE_NAME<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Bind the id to the select statement and execute it<\/span><\/p>\n

\/\/ UUID id = UUID.fromString(“1e4d26ed-922a-4bd2-85cb-6357b202eda8”);<\/span><\/p>\n

BoundStatement <\/span>selectBound<\/span> =<\/span> selectPrepared<\/span>.<\/span>bind<\/span>(<\/span>id<\/span>,<\/span>city<\/span>)<\/span>;<\/span><\/p>\n

ResultSet <\/span>resultSet<\/span> =<\/span> session<\/span>.<\/span>execute<\/span>(<\/span>selectBound<\/span>)<\/span>;<\/span><\/p>\n

\/\/ Print the retrieved data<\/span><\/p>\n

resultSet<\/span>.<\/span>forEach<\/span>(<\/span>row<\/span> -><\/span> System<\/span>.<\/span>out<\/span>.<\/span>println<\/span>(<\/span><\/p>\n

String<\/span>.<\/span>format<\/span>(<\/span>“id: %s, name: %s”<\/span>,<\/span><\/p>\n

row<\/span>.<\/span>getInt<\/span>(<\/span>“emp_id”<\/span>)<\/span>,<\/span><\/p>\n

row<\/span>.<\/span>getString<\/span>(<\/span>“emp_name”<\/span>)<\/span>)<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

closeCassandra<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> removeEmploye<\/span>(<\/span>EmployePOJO <\/span>employe<\/span>)<\/span> throws<\/span> Exception<\/span> {<\/span><\/p>\n

}<\/span><\/p>\n

public<\/span> static<\/span> void<\/span> updateEmploye<\/span>(<\/span>EmployePOJO <\/span>employe<\/span>)<\/span> throws<\/span> Exception<\/span>{<\/span><\/p>\n

}<\/span><\/p>\n

}<\/span><\/p>\n

\u0645\u062f\u06cc\u0631\u06cc\u062a \u0633\u0631\u0648\u0631 \u067e\u0634\u062a\u06cc\u0628\u0627\u0646\u06cc \u0648 \u0645\u0634\u0627\u0648\u0631\u0647 – \u062b\u0628\u062a \u062f\u0627\u0645\u0646\u0647<\/p>\n","protected":false},"excerpt":{"rendered":"

import com.datastax.driver.core.*; \/** * this class is use to handel all interaction between application and data base *\/ public class CassandraDAO { private static Cluster cluster; private static Session session; private final static String KEYSPACE_NAME = “example_keyspace”; private final static String REPLICATION_STRATEGY = “SimpleStrategy”; private final static int REPLICATION_FACTOR = 1; private final static String …<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[35],"tags":[],"class_list":["post-14097","post","type-post","status-publish","format-standard","hentry","category-bigdata"],"_links":{"self":[{"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/posts\/14097","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/comments?post=14097"}],"version-history":[{"count":0,"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/posts\/14097\/revisions"}],"wp:attachment":[{"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/media?parent=14097"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/categories?post=14097"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/afaghhosting.net\/blog\/wp-json\/wp\/v2\/tags?post=14097"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}