APACHE CASSANDRA - BAŞLANGIÇ 2 - Örnek Veritabanı Bağlantısı

Yazan: -


           Cassandra ile başlangıcımızı yapalım. Download için http://cassandra.apache.org/download/ adresini kullanabilirsiniz. Cassandra 3 versiyonları için 1.8 kullanılırken 2 versiyonları için 1.7 kullanılır. Biz testimizde 2.2.6 versiyonunu kullanıyor olacağız.
           
           Download ettikten sonra unzip edip Cassandra yı başlatacağız. Bunun için bin klasörü altındaki cassandra.bat dosyasını çalıştırıyoruz.

Sistem sorunsuz bir şekilde ayağa kalktıktan sonra aynı klasör altında cqlsh.bat dosyasını çalışıtırıp sql console una erişiyoruz.







Bir önceki yazımızdaki örnekdatabase komutunu çalıştıralım. 

 CREATE KEYSPACE ornekdatabase WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1};

sonra 

DESCRIBE keyspaces;

komutuyla hali hazırdaki key spaceleri görebiliyoruz.

Görüldüğü üzere bazı system keyspacelerinin tanımlı olduğunu gözlemliyebiliyoruz.






Şimdi bir tablo oluşturup bu tabloya ait verileri Java dilini kullanarak erişelim.

Örnek tablo için;

use ornekdatabase;

CREATE TABLE users (
        userid text PRIMARY KEY,
        emails set
        );

Insert into  ornekdatabase.users(userid,emails) values('Burak',{'burak@hotmail.com','burak@gmail.com'});




Son olarak örnek kod a geçelim. Maven repo sundan indirilebilirsiniz. Ben 2.2.6 Cassandra için 2.1.10.2 versiyonlu jar la çalıştım sorunsuz bir şekilde.

  


Erişim için örnek kod aşağıdaki gibi.


import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;



public class App 
{
   public static void main(String[] args) {
  
       Cluster cluster;
    Session session;
    
    try {
     cluster = Cluster.builder().addContactPoint("localhost").withPort(9042).build();
     session = cluster.connect("ornekdatabase");
   
     ResultSet results = session.execute("Select * from users");
     
     for (Row row : results) {
         
         System.out.println(row.getString("userid"));
         System.out.println(row.getSet("emails", String.class));
           
     }
     
     
     
    }
    catch (Exception ex) {
    
        ex.printStackTrace();
    
    }
    
  
    
    }
}

Console çıktısında ; 

Burak
[burak@gmail.com, burak@hotmail.com]

gözlemleyeceksiniz.


Yorumlar

Yorum Gönder

Bu blogdaki popüler yayınlar

IONIC BAŞLANGIÇ

Yazan: -
Resim
             Ionic  web tabanlı mobil uygulama geliştirme çatısıdır.  https://ionicframework.com/ adresinden ionic ile ilgili ayrıntılı bilgiye ulaşabilirsiniz. Bu anlatım için angular 2 bilgisi gerekmektedir.     Ionic kullanabilmek için npm gereklidir. Npm paket yönetim programı için https://www.npmjs.com/ .     Node.js yüklemesini de https://nodejs.org/en/ yapıyoruz.     Ionic için Cordova adı verilen mobil fonksiyonlar ile web uygulaması arası bir yapı kurulumu yapılır. npm install –g cordova ionic Yeni bir ionic projesi için ; Ionic start QRScanner blank Komutu ile projeyi oluşturalım. Pluginlerimizi ekliyoruz Camera; ionic cordova plugin add cordova-plugin-camera npm install –save @ionic-native/camera Pluginlerimizi ekliyoruz QRScanner; ionic cordova plugin add cordova-plugin-qrscanner npm install –save @ionic-native/qr-scanner ...
Devamı

Cannot resolve the collation conflict between “Turkish_CI_AS” and “SQL_Latin1_General_CP1_CI_AS” in the equal to operation

Yazan: -
Merhaba Arkadaşlar, Farklı collation lı birden çok veritabanı ile çalışırken bu can sıkıcı hatayla karşılaşıyoruz maalesef. Özellikle joinleme işlemi yaparken aldığımız bu hata ; üzerinde çalıştığımız veritabanındaki tablonun collation ile başka bir veritabanından çağırdığımız tablonun collationlarının uyuşmamasıdır. Çözüm olarak iki yöntemimiz var... 1-) COLLATE DATABASE DEFAULT komutu ile joinlenen veriler arasında collation ı üzerinde çalışılan veritabanın Collation a çevirmek.. Örnek SQL : SELECT T1.EmployeeName, T2.DeptName FROM ServerA.dbo.EmpTab T1 JOIN ServerB.dbo.DeptTab T2 ON T1.DeptCode COLLATE DATABASE_DEFAULT = T2.DeptCode COLLATE DATABASE_DEFAULT  Bu yöntem az joinli sqllerde etkili ve okunabirliliği bozmuyor. 2-)Way efendim benim bir sürü joinim var sql imin okunurluğu bozulmasın diyorsanız dışardan çağrılan veritabanındaki tabloyu select .. into #temp e basarak oluşturduğumuz temp tablonun collationını değiştirdikten sonra onunla çalı...
Devamı

Golang working with interfaces and functions -3

Yazan: -
Resim
When learning Golang one of the interesting part is interfaces. It has a little bit difference with respect to other languages. Let me start with how to identify a typical interface and structs and go over. Here it is following sample interface; type area interface {     getArea () float64 } type square struct {     sideLength float64 } type triangle struct {     height float64     base   float64 } By identifying this interface we expect to implement any structs with respect to its aim. Let me more specific. GetArea method should have math definition that calculates area of received shape.  On the following the calculation square and triangle ; func (s square) getArea () float64 {     return s.sideLength * s.sideLength } func (r triangle) getArea () float64 {     return 0.5 * r.base * r.height } As it is mentioned previous reading they are receiver functions. So same function receives (not parameter) d...
Devamı