ApsaraDB for SelectDB:StarRocks verilerini geçirme

Ön koşullar

• StarRocks örneğiniz ile ApsaraDB for SelectDB örneğiniz arasında SelectDB bağlantısının bulunduğundan emin olun.

  • SelectDB kümesinin tüm düğümleri ve ApsaraDB for SelectDB örneği aynı VPC içinde yer alır. Farklı VPC'lerde bulunuyorlarsa öncelikle ağ bağlantısını kurmanız gerekir. Daha fazla bilgi için bkz. ApsaraDB for SelectDB örneği ile bir veri kaynağı arasında ağ bağlantısı nasıl kurulur?

  • StarRocks örneğinin IP adresini ApsaraDB for SelectDB örneğinin SelectDB listesine ekleyin. Daha fazla bilgi için bkz. Beyaz liste yapılandırma.

  • StarRocks örneğiniz beyaz liste kullanıyorsa SelectDB örneğinizin bulunduğu VPC'nin CIDR bloğunu StarRocks beyaz listesine ekleyin.

    • SelectDB örneğinizin bulunduğu VPC'nin IP aralığını öğrenmek için bkz. ApsaraDB for SelectDB örneğimin bulunduğu VPC'nin IP CIDR bloğunu nasıl bulabilirim?

    • SelectDB örneğinizin genel IP adresini almak için genel uç noktasında ping komutunu çalıştırın SelectDB.

• Catalog'lar ve temel işlemleri hakkında bilgi sahibi olun. Daha fazla bilgi için bkz. Lakehouse Veri İşleme.

Örnek ortam

Bu örnekte StarRocks'taki starRocks_db veritabanındaki SR_t tablosundaki verilerin SelectDB ürünündeki test_db veritabanındaki test_SR2SelectDB tablosuna nasıl geçirileceği gösterilmektedir. Geçiş işlemini gerçekleştirirken parametreleri gerektiği şekilde değiştirin. Örnek ortam aşağıdaki gibidir:

• Hedef veritabanı: test_db

• Hedef tablo: test_SR2SelectDB

• Kaynak veritabanı: starRocks_db

• Kaynak tablo: SR_t

Örnek: Kaynak verileri hazırlama

Kaynak StarRocks örneğinizde oturum açın ve aşağıdaki adımları tamamlayın.

1. Bir veritabanı oluşturun.

   CREATE DATABASE starRocks_db;

2. Bir tablo oluşturun.

   CREATE TABLE SR_t
   (
       id int,
       name string,
       age int
   )
   DISTRIBUTED BY HASH(id) BUCKETS 4
   PROPERTIES("replication_num" = "1");

3. Veri ekleyin.

   INSERT INTO SR_t VALUES
   (1, 'Alice', 25),
   (2, 'Bob', 30),
   (3, 'Charlie', 35),
   (4, 'David', 40),
   (5, 'Eve', 45);

Yordam

1. SelectDB örneğine bağlanın. Daha fazla bilgi için bkz. Örneğe bağlanma.

   Not

   Data Management Service (DMS) kullanarak oturum açtığınızda SWITCH komutu çalışmaz. Bir MySQL istemcisi kullanarak bağlanın.

2. Bir StarRocks JDBC catalog'u oluşturun. Daha fazla bilgi için bkz. JDBC veri kaynağı.

   CREATE CATALOG starrocks_catalog PROPERTIES (
       "type"="jdbc",
       "user"="root",
       "password"="123456",
       "jdbc_url" = "jdbc:mysql://127.0.0.1:3306/demo",
       "driver_url" = "mysql-connector-java-8.0.25.jar",
       "driver_class" = "com.mysql.cj.jdbc.Driver",
       "checksum" = "fdf55dcef04b09f2eaf42b75e61ccc9a"
   )

   Parametreler

   Parametre	Gerekli	Varsayılan değer	Açıklama
   user	Evet	Yok	StarRocks veritabanının hesabı.
   password	Evet	Yok	StarRocks veritabanının parolası.
   jdbc_url	Evet	Yok	JDBC bağlantı dizesi. StarRocks veritabanının bağlantı adresini içermelidir.
   driver_url	Evet	Yok	JDBC sürücüsü JAR paketinin adı. Not mysql-connector-java-8.0.25.jar kullanın. Farklı bir JAR paketi kullanmak için destek talebi oluşturun.
   driver_class	Evet	Yok	JDBC sürücüsünün sınıf adı. Bu parametreyi com.mysql.cj.jdbc.Driver olarak ayarlayın.
   lower_case_table_names (Sürüm 4,0'da lower_case_meta_names olarak yeniden adlandırıldı)	Hayır	"false"	Harici JDBC veri kaynağından gelen veritabanı ve tablo adlarının küçük harfle eşitlenip eşitlenmeyeceğini belirtir. true: Küçük harfli adlardan uzak sistemdeki gerçek adlara bir eşleme tutarak küçük harf olmayan adlara sahip veritabanlarını ve tabloları sorgulamanıza olanak tanır. Bu durumda veritabanı, tablo ve sütun adlarının tamamı küçük harfe dönüştürülür. false: Küçük harf olmayan adlara sahip veritabanlarını ve tabloları sorgulayamazsınız. Önemli SelectDB 3.0 için: FE'nin lower_case_table_names parametresi 1 veya 2 olarak ayarlanmışsa catalog'un lower_case_table_names parametresini true olarak ayarlamanız gerekir. FE'nin lower_case_table_names parametresi 0 olarak ayarlanmışsa catalog parametresi true veya false olarak ayarlanabilir. SelectDB 4.0 için: FE'nin lower_case_table_names parametresi 0 veya 2 olarak ayarlanmışsa veritabanı, tablo ve sütun adları dönüştürülmez. FE'nin lower_case_table_names parametresi 1 olarak ayarlanmışsa tablo adları küçük harfe dönüştürülür ancak veritabanı ve sütun adları dönüştürülmez.
   only_specified_database	Hayır	"false"	Yalnızca belirtilen veritabanının eşitlenip eşitlenmeyeceğini belirtir. true: Yalnızca JDBC URL'sinde belirtilen veritabanını eşitler. false: JDBC URL'sindeki tüm veritabanlarını eşitler.
   include_database_list	Hayır	""	only_specified_database=true olduğunda eşitlenecek veritabanlarını belirtir. Birden çok veritabanını virgülle (,) ayırın. Veritabanı adları büyük/küçük harfe duyarlıdır.
   exclude_database_list	Hayır	""	only_specified_database=true olduğunda eşitlemeden hariç tutulacak veritabanlarını belirtir. Birden çok veritabanını virgülle (,) ayırın. Veritabanı adları büyük/küçük harfe duyarlıdır.
   meta_names_mapping	Hayır	""	Harici veri kaynağında yalnızca büyük/küçük harf farkı olan DORIS ve doris gibi adlar varsa catalog'u sorgulamak belirsizlik nedeniyle hataya neden olabilir. Bu durumda çakışmayı çözmek için meta_names_mapping parametresini yapılandırın. Daha fazla bilgi için bkz. Büyük/küçük harf duyarlılığı ayarları. Önemli Bu parametre yalnızca SelectDB 4,0 için geçerlidir.

3. Catalog'u görüntüleyin.

   SHOW CATALOGS; -- Check if the catalog was created successfully.

   Aşağıdaki sonuç döndürülür.

   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+
   | CatalogId    | CatalogName  | Type     | IsCurrent | CreateTime              | LastUpdateTime      | Comment                |
   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+
   | 436009309195 | SR_catalog | jdbc      |           | 2024-08-06 17:09:08.058 | 2024-07-19 18:04:37 |                        |
   |            0 | internal     | internal | yes       | UNRECORDED              | NULL                | Doris internal catalog |
   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+

4. (İsteğe bağlı) Harici catalog SR_catalog'a geçin.

   Harici catalog SR_catalog'taki verilere dahili bir catalog'ta olduğu gibi bakabilir ve erişebilirsiniz.

   Not

   Şu anda Alibaba Cloud SelectDB yalnızca harici catalog'lardaki verilerde okuma işlemlerini destekler.

   SWITCH SR_catalog;

5. (İsteğe bağlı) Dahili catalog'a geçin.

   4. Adımı gerçekleştirmediyseniz bu adımı atlayın.

   SWITCH internal;

6. (İsteğe bağlı) Bir veritabanı oluşturun.

   Hedef veritabanını zaten oluşturduysanız bu adımı atlayın.

   CREATE database test_db;

7. Hedef veritabanına geçin.

   USE test_db;

8. Bir tablo oluşturun.

   Zaten bir hedef tablonuz varsa hedef tablodaki sütun türlerinin StarRocks kaynak verisindeki sütun türleriyle eşleştiğini kontrol edin.

   Bir hedef tablonuz yoksa tabloyu oluştururken sütun türlerinin StarRocks kaynak verisindeki sütun türleriyle eşleştiğinden emin olun.

   Sütun eşleme hakkında daha fazla bilgi için bkz. Tür eşleme.

   CREATE TABLE test_SR2SelectDB
   (
       id int,
       name string,
       age int
   )
   DISTRIBUTED BY HASH(id) BUCKETS 4
   PROPERTIES("replication_num" = "1");

9. Verileri geçirin.

   INSERT INTO test_SR2SelectDB SELECT *  FROM doris_catalog.SR_db.SR_t;

10. Veri içe aktarma durumunu kontrol edin.

    SELECT *  FROM test_SR2SelectDB;