· 10 years ago · Apr 06, 2016, 07:27 AM
1
2* Embulk: 0.8.8
3* embulk-output-postgresql: 0.5.1
4* embulk-output-mysql: 0.5.1
5* MariaDB: 10.1.2
6* PostgreSQL: 9.5.1
7
8
9PostgreSQL
10
11```
122016-04-05 11:35:31.729 +0900 [INFO] (0001:transaction): SQL: INSERT INTO "account_buyertransaction" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM ...
13```
14
15MySQL
16
17```
182016-04-05 11:42:48.573 +0900 [INFO] (0001:transaction): SQL: INSERT INTO `account_buyertransaction` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM ...
19```
20
21
22
23
24
25
26
27## 2. PostgreSQL
28
29### 2.1 mode: insert, create table on load.
30
31```
322016-04-05 11:35:30.676 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-postgresql (0.5.0)
332016-04-05 11:35:30.740 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
342016-04-05 11:35:30.747 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
352016-04-05 11:35:30.839 +0900 [INFO] (0001:transaction): Using local thread executor with max_threads=8 / output tasks 4 = input tasks 1 * 4
362016-04-05 11:35:30.883 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
372016-04-05 11:35:31.070 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
382016-04-05 11:35:31.092 +0900 [INFO] (0001:transaction): > 0.02 seconds
392016-04-05 11:35:31.092 +0900 [INFO] (0001:transaction): Using insert mode
402016-04-05 11:35:31.143 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp000"
412016-04-05 11:35:31.151 +0900 [INFO] (0001:transaction): > 0.01 seconds
422016-04-05 11:35:31.172 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2160ec00_bl_tmp000" ("id" BIGINT, "session_id" TEXT, "referenceId" TEXT, "paymentMerchant" TEXT, "status" BIGINT, "creation_date" TIMESTAMP WITH TIME ZONE, "user_id" BIGINT, "payment_reason" TEXT, "payment_reason_hash" TEXT)
432016-04-05 11:35:31.192 +0900 [INFO] (0001:transaction): > 0.02 seconds
442016-04-05 11:35:31.194 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp001"
452016-04-05 11:35:31.196 +0900 [INFO] (0001:transaction): > 0.00 seconds
462016-04-05 11:35:31.203 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2160ec00_bl_tmp001" ("id" BIGINT, "session_id" TEXT, "referenceId" TEXT, "paymentMerchant" TEXT, "status" BIGINT, "creation_date" TIMESTAMP WITH TIME ZONE, "user_id" BIGINT, "payment_reason" TEXT, "payment_reason_hash" TEXT)
472016-04-05 11:35:31.206 +0900 [INFO] (0001:transaction): > 0.00 seconds
482016-04-05 11:35:31.207 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp002"
492016-04-05 11:35:31.208 +0900 [INFO] (0001:transaction): > 0.00 seconds
502016-04-05 11:35:31.216 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2160ec00_bl_tmp002" ("id" BIGINT, "session_id" TEXT, "referenceId" TEXT, "paymentMerchant" TEXT, "status" BIGINT, "creation_date" TIMESTAMP WITH TIME ZONE, "user_id" BIGINT, "payment_reason" TEXT, "payment_reason_hash" TEXT)
512016-04-05 11:35:31.220 +0900 [INFO] (0001:transaction): > 0.00 seconds
522016-04-05 11:35:31.221 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp003"
532016-04-05 11:35:31.223 +0900 [INFO] (0001:transaction): > 0.00 seconds
542016-04-05 11:35:31.229 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2160ec00_bl_tmp003" ("id" BIGINT, "session_id" TEXT, "referenceId" TEXT, "paymentMerchant" TEXT, "status" BIGINT, "creation_date" TIMESTAMP WITH TIME ZONE, "user_id" BIGINT, "payment_reason" TEXT, "payment_reason_hash" TEXT)
552016-04-05 11:35:31.237 +0900 [INFO] (0001:transaction): > 0.01 seconds
562016-04-05 11:35:31.334 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
572016-04-05 11:35:31.383 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
582016-04-05 11:35:31.402 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
592016-04-05 11:35:31.403 +0900 [INFO] (0017:task-0000): > 0.00 seconds
602016-04-05 11:35:31.404 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2160ec00_bl_tmp000" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
612016-04-05 11:35:31.409 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
622016-04-05 11:35:31.419 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
632016-04-05 11:35:31.420 +0900 [INFO] (0017:task-0000): > 0.00 seconds
642016-04-05 11:35:31.420 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2160ec00_bl_tmp001" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
652016-04-05 11:35:31.423 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
662016-04-05 11:35:31.438 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
672016-04-05 11:35:31.439 +0900 [INFO] (0017:task-0000): > 0.00 seconds
682016-04-05 11:35:31.440 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2160ec00_bl_tmp002" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
692016-04-05 11:35:31.441 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
702016-04-05 11:35:31.452 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
712016-04-05 11:35:31.453 +0900 [INFO] (0017:task-0000): > 0.00 seconds
722016-04-05 11:35:31.453 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2160ec00_bl_tmp003" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
732016-04-05 11:35:31.625 +0900 [INFO] (0017:task-0000): Loading 11 rows (695 bytes)
742016-04-05 11:35:31.652 +0900 [INFO] (0017:task-0000): > 0.03 seconds (loaded 11 rows in total)
752016-04-05 11:35:31.670 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
762016-04-05 11:35:31.671 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=28800}
772016-04-05 11:35:31.684 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
782016-04-05 11:35:31.686 +0900 [INFO] (0001:transaction): > 0.00 seconds
792016-04-05 11:35:31.692 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buyertransaction" ("id" BIGINT, "session_id" TEXT, "referenceId" TEXT, "paymentMerchant" TEXT, "status" BIGINT, "creation_date" TIMESTAMP WITH TIME ZONE, "user_id" BIGINT, "payment_reason" TEXT, "payment_reason_hash" TEXT)
802016-04-05 11:35:31.700 +0900 [INFO] (0001:transaction): > 0.01 seconds
812016-04-05 11:35:31.729 +0900 [INFO] (0001:transaction): SQL: INSERT INTO "account_buyertransaction" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2160ec00_bl_tmp000" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2160ec00_bl_tmp001" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2160ec00_bl_tmp002" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2160ec00_bl_tmp003"
822016-04-05 11:35:31.735 +0900 [INFO] (0001:transaction): > 0.01 seconds (11 rows)
832016-04-05 11:35:31.752 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
842016-04-05 11:35:31.763 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
852016-04-05 11:35:31.764 +0900 [INFO] (0001:transaction): > 0.00 seconds
862016-04-05 11:35:31.765 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp000"
872016-04-05 11:35:31.773 +0900 [INFO] (0001:transaction): > 0.01 seconds
882016-04-05 11:35:31.774 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp001"
892016-04-05 11:35:31.776 +0900 [INFO] (0001:transaction): > 0.00 seconds
902016-04-05 11:35:31.776 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp002"
912016-04-05 11:35:31.779 +0900 [INFO] (0001:transaction): > 0.00 seconds
922016-04-05 11:35:31.779 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp003"
932016-04-05 11:35:31.784 +0900 [INFO] (0001:transaction): > 0.00 seconds
942016-04-05 11:35:31.788 +0900 [INFO] (main): Committed.
952016-04-05 11:35:31.788 +0900 [INFO] (main): Next config diff: {"in":{"last_path":"hoge.csv"},"out":{}}
96```
97
98### 2.2 mode: insert. create table before load
99
100Need quote
101
102```sql
103CREATE TABLE account_buyertransaction (
104 id integer,
105 session_id varchar(64),
106 "referenceId" varchar(32),
107 "paymentMerchant" varchar(32),
108 status integer,
109 creation_date timestamp,
110 user_id bigint,
111 payment_reason text,
112 payment_reason_hash text
113) ;
114```
115
116
117
118```
1192016-04-05 11:39:05.866 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-postgresql (0.5.0)
1202016-04-05 11:39:05.934 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
1212016-04-05 11:39:05.944 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
1222016-04-05 11:39:06.037 +0900 [INFO] (0001:transaction): Using local thread executor with max_threads=8 / output tasks 4 = input tasks 1 * 4
1232016-04-05 11:39:06.062 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1242016-04-05 11:39:06.230 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
1252016-04-05 11:39:06.233 +0900 [INFO] (0001:transaction): > 0.00 seconds
1262016-04-05 11:39:06.233 +0900 [INFO] (0001:transaction): Using insert mode
1272016-04-05 11:39:06.265 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp000"
1282016-04-05 11:39:06.268 +0900 [INFO] (0001:transaction): > 0.00 seconds
1292016-04-05 11:39:06.286 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2aad4b00_bl_tmp000" ("id" INT4, "session_id" VARCHAR(64), "referenceId" VARCHAR(32), "paymentMerchant" VARCHAR(32), "status" INT4, "creation_date" TIMESTAMP, "user_id" INT8, "payment_reason" TEXT, "payment_reason_hash" TEXT)
1302016-04-05 11:39:06.290 +0900 [INFO] (0001:transaction): > 0.00 seconds
1312016-04-05 11:39:06.291 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp001"
1322016-04-05 11:39:06.292 +0900 [INFO] (0001:transaction): > 0.00 seconds
1332016-04-05 11:39:06.297 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2aad4b00_bl_tmp001" ("id" INT4, "session_id" VARCHAR(64), "referenceId" VARCHAR(32), "paymentMerchant" VARCHAR(32), "status" INT4, "creation_date" TIMESTAMP, "user_id" INT8, "payment_reason" TEXT, "payment_reason_hash" TEXT)
1342016-04-05 11:39:06.304 +0900 [INFO] (0001:transaction): > 0.01 seconds
1352016-04-05 11:39:06.305 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp002"
1362016-04-05 11:39:06.306 +0900 [INFO] (0001:transaction): > 0.00 seconds
1372016-04-05 11:39:06.312 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2aad4b00_bl_tmp002" ("id" INT4, "session_id" VARCHAR(64), "referenceId" VARCHAR(32), "paymentMerchant" VARCHAR(32), "status" INT4, "creation_date" TIMESTAMP, "user_id" INT8, "payment_reason" TEXT, "payment_reason_hash" TEXT)
1382016-04-05 11:39:06.315 +0900 [INFO] (0001:transaction): > 0.00 seconds
1392016-04-05 11:39:06.316 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp003"
1402016-04-05 11:39:06.317 +0900 [INFO] (0001:transaction): > 0.00 seconds
1412016-04-05 11:39:06.322 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS "account_buy_2aad4b00_bl_tmp003" ("id" INT4, "session_id" VARCHAR(64), "referenceId" VARCHAR(32), "paymentMerchant" VARCHAR(32), "status" INT4, "creation_date" TIMESTAMP, "user_id" INT8, "payment_reason" TEXT, "payment_reason_hash" TEXT)
1422016-04-05 11:39:06.325 +0900 [INFO] (0001:transaction): > 0.00 seconds
1432016-04-05 11:39:06.382 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
1442016-04-05 11:39:06.430 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1452016-04-05 11:39:06.447 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
1462016-04-05 11:39:06.448 +0900 [INFO] (0017:task-0000): > 0.00 seconds
1472016-04-05 11:39:06.450 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2aad4b00_bl_tmp000" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
1482016-04-05 11:39:06.456 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1492016-04-05 11:39:06.468 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
1502016-04-05 11:39:06.470 +0900 [INFO] (0017:task-0000): > 0.00 seconds
1512016-04-05 11:39:06.470 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2aad4b00_bl_tmp001" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
1522016-04-05 11:39:06.472 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1532016-04-05 11:39:06.487 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
1542016-04-05 11:39:06.489 +0900 [INFO] (0017:task-0000): > 0.00 seconds
1552016-04-05 11:39:06.489 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2aad4b00_bl_tmp002" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
1562016-04-05 11:39:06.491 +0900 [INFO] (0017:task-0000): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1572016-04-05 11:39:06.503 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
1582016-04-05 11:39:06.504 +0900 [INFO] (0017:task-0000): > 0.00 seconds
1592016-04-05 11:39:06.505 +0900 [INFO] (0017:task-0000): Copy SQL: COPY "account_buy_2aad4b00_bl_tmp003" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") FROM STDIN
1602016-04-05 11:39:06.662 +0900 [INFO] (0017:task-0000): Loading 11 rows (695 bytes)
1612016-04-05 11:39:06.672 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
1622016-04-05 11:39:06.677 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
1632016-04-05 11:39:06.678 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=28800}
1642016-04-05 11:39:06.687 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
1652016-04-05 11:39:06.690 +0900 [INFO] (0001:transaction): > 0.00 seconds
1662016-04-05 11:39:06.691 +0900 [INFO] (0001:transaction): SQL: INSERT INTO "account_buyertransaction" ("id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash") SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2aad4b00_bl_tmp000" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2aad4b00_bl_tmp001" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2aad4b00_bl_tmp002" UNION ALL SELECT "id", "session_id", "referenceId", "paymentMerchant", "status", "creation_date", "user_id", "payment_reason", "payment_reason_hash" FROM "account_buy_2aad4b00_bl_tmp003"
1672016-04-05 11:39:06.695 +0900 [INFO] (0001:transaction): > 0.00 seconds (11 rows)
1682016-04-05 11:39:06.727 +0900 [INFO] (0001:transaction): Connecting to jdbc:postgresql://localhost:5432/embulk_test options {user=user, tcpKeepAlive=true, loginTimeout=300, socketTimeout=1800}
1692016-04-05 11:39:06.736 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
1702016-04-05 11:39:06.739 +0900 [INFO] (0001:transaction): > 0.00 seconds
1712016-04-05 11:39:06.739 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp000"
1722016-04-05 11:39:06.745 +0900 [INFO] (0001:transaction): > 0.01 seconds
1732016-04-05 11:39:06.746 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp001"
1742016-04-05 11:39:06.750 +0900 [INFO] (0001:transaction): > 0.00 seconds
1752016-04-05 11:39:06.752 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp002"
1762016-04-05 11:39:06.754 +0900 [INFO] (0001:transaction): > 0.00 seconds
1772016-04-05 11:39:06.755 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp003"
1782016-04-05 11:39:06.757 +0900 [INFO] (0001:transaction): > 0.00 seconds
1792016-04-05 11:39:06.761 +0900 [INFO] (main): Committed.
1802016-04-05 11:39:06.762 +0900 [INFO] (main): Next config diff: {"in":{"last_path":"hoge.csv"},"out":{}}
181```
182
183```
184embulk_test=# \d account_buyertransaction ;
185 Table "public.account_buyertransaction"
186 Column | Type | Modifiers
187---------------------+-----------------------------+-----------
188 id | integer |
189 session_id | character varying(64) |
190 referenceId | character varying(32) |
191 paymentMerchant | character varying(32) |
192 status | integer |
193 creation_date | timestamp without time zone |
194 user_id | bigint |
195 payment_reason | text |
196 payment_reason_hash | text |
197```
198
199
200## 3. MySQL
201
202### 3.1 mode: insert, create table on load.
203
204
205```
2062016-04-05 11:40:43.675 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-mysql (0.5.1)
2072016-04-05 11:40:43.748 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
2082016-04-05 11:40:43.757 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
2092016-04-05 11:40:43.838 +0900 [INFO] (0001:transaction): Using local thread executor with max_threads=8 / output tasks 4 = input tasks 1 * 4
2102016-04-05 11:40:43.860 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2112016-04-05 11:40:44.232 +0900 [INFO] (0001:transaction): Using insert mode
2122016-04-05 11:40:44.239 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000`
2132016-04-05 11:40:44.245 +0900 [INFO] (0001:transaction): > 0.01 seconds
2142016-04-05 11:40:44.264 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000` (`id` BIGINT, `session_id` TEXT, `referenceId` TEXT, `paymentMerchant` TEXT, `status` BIGINT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2152016-04-05 11:40:44.325 +0900 [INFO] (0001:transaction): > 0.06 seconds
2162016-04-05 11:40:44.326 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001`
2172016-04-05 11:40:44.327 +0900 [INFO] (0001:transaction): > 0.00 seconds
2182016-04-05 11:40:44.334 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001` (`id` BIGINT, `session_id` TEXT, `referenceId` TEXT, `paymentMerchant` TEXT, `status` BIGINT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2192016-04-05 11:40:44.371 +0900 [INFO] (0001:transaction): > 0.04 seconds
2202016-04-05 11:40:44.372 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002`
2212016-04-05 11:40:44.372 +0900 [INFO] (0001:transaction): > 0.00 seconds
2222016-04-05 11:40:44.377 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002` (`id` BIGINT, `session_id` TEXT, `referenceId` TEXT, `paymentMerchant` TEXT, `status` BIGINT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2232016-04-05 11:40:44.404 +0900 [INFO] (0001:transaction): > 0.03 seconds
2242016-04-05 11:40:44.406 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003`
2252016-04-05 11:40:44.408 +0900 [INFO] (0001:transaction): > 0.00 seconds
2262016-04-05 11:40:44.414 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003` (`id` BIGINT, `session_id` TEXT, `referenceId` TEXT, `paymentMerchant` TEXT, `status` BIGINT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2272016-04-05 11:40:44.442 +0900 [INFO] (0001:transaction): > 0.03 seconds
2282016-04-05 11:40:44.519 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
2292016-04-05 11:40:44.574 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2302016-04-05 11:40:44.591 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
2312016-04-05 11:40:44.619 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2322016-04-05 11:40:44.632 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
2332016-04-05 11:40:44.636 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2342016-04-05 11:40:44.648 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
2352016-04-05 11:40:44.651 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2362016-04-05 11:40:44.671 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
2372016-04-05 11:40:44.843 +0900 [INFO] (0017:task-0000): Loading 11 rows
2382016-04-05 11:40:44.856 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
2392016-04-05 11:40:44.857 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
2402016-04-05 11:40:44.858 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=2700000}
2412016-04-05 11:40:44.872 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction` (`id` BIGINT, `session_id` TEXT, `referenceId` TEXT, `paymentMerchant` TEXT, `status` BIGINT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2422016-04-05 11:40:44.902 +0900 [INFO] (0001:transaction): > 0.03 seconds
2432016-04-05 11:40:44.903 +0900 [INFO] (0001:transaction): SQL: INSERT INTO `account_buyertransaction` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003`
2442016-04-05 11:40:44.945 +0900 [INFO] (0001:transaction): > 0.04 seconds (11 rows)
2452016-04-05 11:40:44.956 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2462016-04-05 11:40:44.965 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000`
2472016-04-05 11:40:44.968 +0900 [INFO] (0001:transaction): > 0.00 seconds
2482016-04-05 11:40:44.969 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001`
2492016-04-05 11:40:44.975 +0900 [INFO] (0001:transaction): > 0.01 seconds
2502016-04-05 11:40:44.976 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002`
2512016-04-05 11:40:44.979 +0900 [INFO] (0001:transaction): > 0.00 seconds
2522016-04-05 11:40:44.980 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003`
2532016-04-05 11:40:44.989 +0900 [INFO] (0001:transaction): > 0.01 seconds
2542016-04-05 11:40:44.992 +0900 [INFO] (main): Committed.
2552016-04-05 11:40:44.993 +0900 [INFO] (main): Next config diff: {"in":{"last_path":"hoge.csv"},"out":{}}
256```
257
258### 3.2 mode: insert, create table before load.
259
260```sql
261CREATE TABLE account_buyertransaction (
262 id integer,
263 session_id varchar(64),
264 referenceId varchar(32),
265 paymentMerchant varchar(32),
266 status integer,
267 creation_date timestamp,
268 user_id bigint,
269 payment_reason text,
270 payment_reason_hash text
271) ;
272```
273
274```
2752016-04-05 11:42:44.715 +0900: Embulk v0.8.8
2762016-04-05 11:42:47.325 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-mysql (0.5.1)
2772016-04-05 11:42:47.397 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
2782016-04-05 11:42:47.410 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
2792016-04-05 11:42:47.512 +0900 [INFO] (0001:transaction): Using local thread executor with max_threads=8 / output tasks 4 = input tasks 1 * 4
2802016-04-05 11:42:47.547 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
2812016-04-05 11:42:48.058 +0900 [INFO] (0001:transaction): Using insert mode
2822016-04-05 11:42:48.080 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp000`
2832016-04-05 11:42:48.086 +0900 [INFO] (0001:transaction): > 0.00 seconds
2842016-04-05 11:42:48.106 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp000` (`id` INT, `session_id` VARCHAR(64), `referenceId` VARCHAR(32), `paymentMerchant` VARCHAR(32), `status` INT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2852016-04-05 11:42:48.140 +0900 [INFO] (0001:transaction): > 0.03 seconds
2862016-04-05 11:42:48.141 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp001`
2872016-04-05 11:42:48.142 +0900 [INFO] (0001:transaction): > 0.00 seconds
2882016-04-05 11:42:48.149 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp001` (`id` INT, `session_id` VARCHAR(64), `referenceId` VARCHAR(32), `paymentMerchant` VARCHAR(32), `status` INT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2892016-04-05 11:42:48.169 +0900 [INFO] (0001:transaction): > 0.02 seconds
2902016-04-05 11:42:48.169 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp002`
2912016-04-05 11:42:48.170 +0900 [INFO] (0001:transaction): > 0.00 seconds
2922016-04-05 11:42:48.176 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp002` (`id` INT, `session_id` VARCHAR(64), `referenceId` VARCHAR(32), `paymentMerchant` VARCHAR(32), `status` INT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2932016-04-05 11:42:48.198 +0900 [INFO] (0001:transaction): > 0.02 seconds
2942016-04-05 11:42:48.199 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp003`
2952016-04-05 11:42:48.200 +0900 [INFO] (0001:transaction): > 0.00 seconds
2962016-04-05 11:42:48.205 +0900 [INFO] (0001:transaction): SQL: CREATE TABLE IF NOT EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp003` (`id` INT, `session_id` VARCHAR(64), `referenceId` VARCHAR(32), `paymentMerchant` VARCHAR(32), `status` INT, `creation_date` TIMESTAMP, `user_id` BIGINT, `payment_reason` TEXT, `payment_reason_hash` TEXT)
2972016-04-05 11:42:48.231 +0900 [INFO] (0001:transaction): > 0.03 seconds
2982016-04-05 11:42:48.280 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
2992016-04-05 11:42:48.324 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
3002016-04-05 11:42:48.341 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570326270a408300_bl_tmp000` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
3012016-04-05 11:42:48.359 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
3022016-04-05 11:42:48.370 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570326270a408300_bl_tmp001` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
3032016-04-05 11:42:48.373 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
3042016-04-05 11:42:48.383 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570326270a408300_bl_tmp002` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
3052016-04-05 11:42:48.385 +0900 [INFO] (0017:task-0000): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
3062016-04-05 11:42:48.400 +0900 [INFO] (0017:task-0000): Prepared SQL: INSERT INTO `account_buyertransaction_00000000570326270a408300_bl_tmp003` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
3072016-04-05 11:42:48.556 +0900 [INFO] (0017:task-0000): Loading 11 rows
3082016-04-05 11:42:48.561 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
3092016-04-05 11:42:48.562 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
3102016-04-05 11:42:48.563 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=2700000}
3112016-04-05 11:42:48.573 +0900 [INFO] (0001:transaction): SQL: INSERT INTO `account_buyertransaction` (`id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash`) SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570326270a408300_bl_tmp000` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570326270a408300_bl_tmp001` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570326270a408300_bl_tmp002` UNION ALL SELECT `id`, `session_id`, `referenceId`, `paymentMerchant`, `status`, `creation_date`, `user_id`, `payment_reason`, `payment_reason_hash` FROM `account_buyertransaction_00000000570326270a408300_bl_tmp003`
3122016-04-05 11:42:48.577 +0900 [INFO] (0001:transaction): > 0.00 seconds (11 rows)
3132016-04-05 11:42:48.586 +0900 [INFO] (0001:transaction): Connecting to jdbc:mysql://localhost:3306/embulk_test options {user=root, tcpKeepAlive=true, useCompression=true, rewriteBatchedStatements=true, connectTimeout=300000, socketTimeout=1800000}
3142016-04-05 11:42:48.595 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp000`
3152016-04-05 11:42:48.598 +0900 [INFO] (0001:transaction): > 0.00 seconds
3162016-04-05 11:42:48.598 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp001`
3172016-04-05 11:42:48.606 +0900 [INFO] (0001:transaction): > 0.01 seconds
3182016-04-05 11:42:48.607 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp002`
3192016-04-05 11:42:48.611 +0900 [INFO] (0001:transaction): > 0.00 seconds
3202016-04-05 11:42:48.611 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp003`
3212016-04-05 11:42:48.615 +0900 [INFO] (0001:transaction): > 0.00 seconds
3222016-04-05 11:42:48.622 +0900 [INFO] (main): Committed.
3232016-04-05 11:42:48.622 +0900 [INFO] (main): Next config diff: {"in":{"last_path":"hoge.csv"},"out":{}}
324```
325
326### table
327
328```
329+---------------------+------------+------+-----+-------------------+-----------------------------+
330| Field | Type | Null | Key | Default | Extra |
331+---------------------+------------+------+-----+-------------------+-----------------------------+
332| id | bigint(20) | YES | | NULL | |
333| session_id | text | YES | | NULL | |
334| referenceId | text | YES | | NULL | |
335| paymentMerchant | text | YES | | NULL | |
336| status | bigint(20) | YES | | NULL | |
337| creation_date | timestamp | NO | | CURRENT_TIMESTAMP | on update CURRENT_TIMESTAMP |
338| user_id | bigint(20) | YES | | NULL | |
339| payment_reason | text | YES | | NULL | |
340| payment_reason_hash | text | YES | | NULL | |
341+---------------------+------------+------+-----+-------------------+-----------------------------+
342```