UUID metodu

Giriş

Açıklaması şöyle

For instance, the UUID() MySQL function returns a version 1 UUID number.

And the Java UUID.randomUUID() function returns a version 4 UUID number.

root Kullanıcı - Administrator

MySQL kurulunca genellikle root isimli bir administrator kullanıcı yaratılır

JDBC DatabaseMetaData.getTables metodu

Giriş

Bir makale burada. MySQL açısından bir veri tabanı şeklen şöyle

db 			<-- Ben yarattım
information_schema
mysql                   <-- MySQL kurulumu ile geliyor
performance_schema
sys

Açıklaması şöyle

The MySQL installation comes with default databases. One of the database is named 'mysql'.

db veri tabanını yaratmak için şöyle yaptım

CREATE TABLE IF NOT EXISTS db.myworker (...);

Örnek - catalog değeri geç

Elimizde şöyle bir kod olsun

try (Connection connection = ...;
     ResultSet tables = connection.getMetaData().getTables(
        connection.getCatalog(),
        null,
        null,
        new String[]{"TABLE", "VIEW"})) {
  ...
}

1. Eğer bağlantı şöyle ise yani veri tabanı belirtilmemişse 

jdbc:mysql://localhost:3306/

connection.getCatalog() çağrısı "" döner

connection.getSchema() çağrısı null döner

ResultSet te boş geliyor

2. Eğer bağlantı şöyle ise yani veri tabanı belirtilmişse

jdbc:mysql://localhost:3306/db

connection.getCatalog() çağrısı db döner

connection.getSchema() çağrısı null döner

ResultSet dolu gelir ve içinde sadece db veri tabanında yarattığım tabloları görürüm

Örnek - catalog null yani catalog değeri geçme

Elimizde şöyle bir kod olsun. Bu sefer catalog yerine null geçtim. 

try (Connection connection = ...;
     ResultSet tables = connection.getMetaData().getTables(
        null,
        null,
        null,
        new String[]{"TABLE", "VIEW"})) {
  ...
}

1. Eğer bağlantı şöyle ise yani veri tabanı belirtilmemişse 

jdbc:mysql://localhost:3306/

connection.getCatalog() çağrısı "" döner

connection.getSchema() çağrısı null döner

ResultSet  dolu gelir ve içinde sys ve db dahil her şeyi görürüm. Çünkü catalog değeri olarak null geçtim

2. Eğer bağlantı şöyle ise yani veri tabanı belirtilmişse

jdbc:mysql://localhost:3306/db

connection.getCatalog() çağrısı db döner

connection.getSchema() çağrısı null döner

ResultSet  dolu gelir ve içinde sys ve db dahil her şeyi görürüm. Çünkü catalog değeri olarak null geçtim

EXPLAIN ANALYZE

JSON Çıktı

Açıklaması şöyle

Starting from MySQL 9.0.0, it is now possible to save the JSON output of the EXPLAIN ANALYZE command into a user variable using the following new syntax:
EXPLAIN ANALYZE FORMAT=JSON INTO @variable select_stmt

Açıklaması şöyle

The INTO clause is only supported with FORMAT=JSON; FORMAT must be explicitly specified. This form of EXPLAIN ANALYZE also supports optional FOR SCHEMA or FOR DATABASE clauses.

Table Scan

Full Scan anlamına gelir. 

Örnek

Şöyle yaparız. id alanında index veya primary key olmadığı için tüm tabloyu tarar

mysql> explain analyze select * from employee1 where id = 3456;
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| EXPLAIN                                                                                                                                                                                               |
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| -> Filter: (employee1.id = 3456)  (cost=1989 rows=1965) (actual time=5.24..29.3 rows=1 loops=1)
    -> Table scan on employee1  (cost=1989 rows=19651) (actual time=0.0504..27.3 rows=20000 loops=1)
 |
+--------------------------------------------------------------------------------------------------------

Index lookup

Örnek

Tablo için bir indeks yaratalım

CREATE INDEX index1 ON employee1 (FirstName);

Şöyle yaparız. FirstName alanında index olduğu için tüm indeksi tarar

mysql> explain analyze select * from employee1 where FirstName = 'user-13456';
+-------------------------------------------------------------------------------------------------------------------------------------+
| EXPLAIN                                                                                                                             |
+-------------------------------------------------------------------------------------------------------------------------------------+
| -> Index lookup on employee1 using index1 (FirstName='user-13456')  (cost=0.35 rows=1) (actual time=0.0594..0.0669 rows=1 loops=1)
 |
+-------------------------------------------------------------------------------------------------------------------------------------+
1 row in set (0.00 sec)

SHOW INDEXES

Örnek

Şöyle yaparız

mysql> SHOW INDEXES FROM employee2 \G;
*************************** 1. row ***************************
        Table: employee2
   Non_unique: 0
     Key_name: PRIMARY
 Seq_in_index: 1
  Column_name: id
    Collation: A
  Cardinality: 0
     Sub_part: NULL
       Packed: NULL
         Null: 
   Index_type: BTREE
      Comment: 
Index_comment: 
      Visible: YES
   Expression: NULL
1 row in set (0.00 sec)

SET GLOBAL

Örnek

Şöyle yaparız

mysql> SET GLOBAL validate_password.policy = 0;
mysql> ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'password';

Debezium Connector transforms - ExtractNewRecordState - Sadece Değişen Alan Gelir

Giriş

Şu iki satırı yazmak gerekir.

1. transforms": "unwrap"

2. "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",

Böylece çıktıda  before alanı hep null gelir. Yani şöyledir

{
  "source": {
    ...
  },
  "before": null,
  "after": {
    "id": 1,
    "name": "John Doe",
    "age": 30
  },
  "op": "c",
  "ts_ms": 1654316585000
}

Açıklaması şöyle

By default, Debezium sends all events in an envelope that includes many pieces of information about the change captured. I’m only interested in reading the changed value here, so the command tells Kafka Connect to keep this information and discard the rest.

Örnek

Şöyle yaparız

{
  "name":"customer-connector",
  "config":{
   "connector.class":"io.debezium.connector.mysql.MySqlConnector",
   "tasks.max":"1",
   "database.hostname":"localhost",
   "database.port":"3306",
   "database.user":"root",
   "database.password":"mysqlpwd",
   "database.server.id":"184054",
   "database.server.name":"mysql",
   "database.whitelist":"customers_db",
   "database.history.kafka.bootstrap.servers":"localhost:9092",
   "database.history.kafka.topic":"schema-changes.customers",
   "transforms":"unwrap",    "transforms.unwrap.type":"io.debezium.transforms.ExtractNewRecordState",
    "transforms.unwrap.drop.tombstones":false,
    "transforms.unwrap.delete.handling.mode":"rewrite"
   }
}