API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Apr 6th, 2016
137
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 38.16 KB | None | 0 0
raw download clone embed print report
  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.  
  9. PostgreSQL
  10.  
  11. ```
  12. 2016-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.  
  15. MySQL
  16.  
  17. ```
  18. 2016-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. ```
  32. 2016-04-05 11:35:30.676 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-postgresql (0.5.0)
  33. 2016-04-05 11:35:30.740 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
  34. 2016-04-05 11:35:30.747 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
  35. 2016-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
  36. 2016-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}
  37. 2016-04-05 11:35:31.070 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  38. 2016-04-05 11:35:31.092 +0900 [INFO] (0001:transaction): > 0.02 seconds
  39. 2016-04-05 11:35:31.092 +0900 [INFO] (0001:transaction): Using insert mode
  40. 2016-04-05 11:35:31.143 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp000"
  41. 2016-04-05 11:35:31.151 +0900 [INFO] (0001:transaction): > 0.01 seconds
  42. 2016-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)
  43. 2016-04-05 11:35:31.192 +0900 [INFO] (0001:transaction): > 0.02 seconds
  44. 2016-04-05 11:35:31.194 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp001"
  45. 2016-04-05 11:35:31.196 +0900 [INFO] (0001:transaction): > 0.00 seconds
  46. 2016-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)
  47. 2016-04-05 11:35:31.206 +0900 [INFO] (0001:transaction): > 0.00 seconds
  48. 2016-04-05 11:35:31.207 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp002"
  49. 2016-04-05 11:35:31.208 +0900 [INFO] (0001:transaction): > 0.00 seconds
  50. 2016-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)
  51. 2016-04-05 11:35:31.220 +0900 [INFO] (0001:transaction): > 0.00 seconds
  52. 2016-04-05 11:35:31.221 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp003"
  53. 2016-04-05 11:35:31.223 +0900 [INFO] (0001:transaction): > 0.00 seconds
  54. 2016-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)
  55. 2016-04-05 11:35:31.237 +0900 [INFO] (0001:transaction): > 0.01 seconds
  56. 2016-04-05 11:35:31.334 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
  57. 2016-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}
  58. 2016-04-05 11:35:31.402 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  59. 2016-04-05 11:35:31.403 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  60. 2016-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
  61. 2016-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}
  62. 2016-04-05 11:35:31.419 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  63. 2016-04-05 11:35:31.420 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  64. 2016-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
  65. 2016-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}
  66. 2016-04-05 11:35:31.438 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  67. 2016-04-05 11:35:31.439 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  68. 2016-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
  69. 2016-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}
  70. 2016-04-05 11:35:31.452 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  71. 2016-04-05 11:35:31.453 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  72. 2016-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
  73. 2016-04-05 11:35:31.625 +0900 [INFO] (0017:task-0000): Loading 11 rows (695 bytes)
  74. 2016-04-05 11:35:31.652 +0900 [INFO] (0017:task-0000): > 0.03 seconds (loaded 11 rows in total)
  75. 2016-04-05 11:35:31.670 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
  76. 2016-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}
  77. 2016-04-05 11:35:31.684 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  78. 2016-04-05 11:35:31.686 +0900 [INFO] (0001:transaction): > 0.00 seconds
  79. 2016-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)
  80. 2016-04-05 11:35:31.700 +0900 [INFO] (0001:transaction): > 0.01 seconds
  81. 2016-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"
  82. 2016-04-05 11:35:31.735 +0900 [INFO] (0001:transaction): > 0.01 seconds (11 rows)
  83. 2016-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}
  84. 2016-04-05 11:35:31.763 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  85. 2016-04-05 11:35:31.764 +0900 [INFO] (0001:transaction): > 0.00 seconds
  86. 2016-04-05 11:35:31.765 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp000"
  87. 2016-04-05 11:35:31.773 +0900 [INFO] (0001:transaction): > 0.01 seconds
  88. 2016-04-05 11:35:31.774 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp001"
  89. 2016-04-05 11:35:31.776 +0900 [INFO] (0001:transaction): > 0.00 seconds
  90. 2016-04-05 11:35:31.776 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp002"
  91. 2016-04-05 11:35:31.779 +0900 [INFO] (0001:transaction): > 0.00 seconds
  92. 2016-04-05 11:35:31.779 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2160ec00_bl_tmp003"
  93. 2016-04-05 11:35:31.784 +0900 [INFO] (0001:transaction): > 0.00 seconds
  94. 2016-04-05 11:35:31.788 +0900 [INFO] (main): Committed.
  95. 2016-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.  
  100. Need quote
  101.  
  102. ```sql
  103. CREATE 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. ```
  119. 2016-04-05 11:39:05.866 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-postgresql (0.5.0)
  120. 2016-04-05 11:39:05.934 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
  121. 2016-04-05 11:39:05.944 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
  122. 2016-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
  123. 2016-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}
  124. 2016-04-05 11:39:06.230 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  125. 2016-04-05 11:39:06.233 +0900 [INFO] (0001:transaction): > 0.00 seconds
  126. 2016-04-05 11:39:06.233 +0900 [INFO] (0001:transaction): Using insert mode
  127. 2016-04-05 11:39:06.265 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp000"
  128. 2016-04-05 11:39:06.268 +0900 [INFO] (0001:transaction): > 0.00 seconds
  129. 2016-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)
  130. 2016-04-05 11:39:06.290 +0900 [INFO] (0001:transaction): > 0.00 seconds
  131. 2016-04-05 11:39:06.291 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp001"
  132. 2016-04-05 11:39:06.292 +0900 [INFO] (0001:transaction): > 0.00 seconds
  133. 2016-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)
  134. 2016-04-05 11:39:06.304 +0900 [INFO] (0001:transaction): > 0.01 seconds
  135. 2016-04-05 11:39:06.305 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp002"
  136. 2016-04-05 11:39:06.306 +0900 [INFO] (0001:transaction): > 0.00 seconds
  137. 2016-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)
  138. 2016-04-05 11:39:06.315 +0900 [INFO] (0001:transaction): > 0.00 seconds
  139. 2016-04-05 11:39:06.316 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp003"
  140. 2016-04-05 11:39:06.317 +0900 [INFO] (0001:transaction): > 0.00 seconds
  141. 2016-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)
  142. 2016-04-05 11:39:06.325 +0900 [INFO] (0001:transaction): > 0.00 seconds
  143. 2016-04-05 11:39:06.382 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
  144. 2016-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}
  145. 2016-04-05 11:39:06.447 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  146. 2016-04-05 11:39:06.448 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  147. 2016-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
  148. 2016-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}
  149. 2016-04-05 11:39:06.468 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  150. 2016-04-05 11:39:06.470 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  151. 2016-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
  152. 2016-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}
  153. 2016-04-05 11:39:06.487 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  154. 2016-04-05 11:39:06.489 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  155. 2016-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
  156. 2016-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}
  157. 2016-04-05 11:39:06.503 +0900 [INFO] (0017:task-0000): SQL: SET search_path TO "public"
  158. 2016-04-05 11:39:06.504 +0900 [INFO] (0017:task-0000): > 0.00 seconds
  159. 2016-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
  160. 2016-04-05 11:39:06.662 +0900 [INFO] (0017:task-0000): Loading 11 rows (695 bytes)
  161. 2016-04-05 11:39:06.672 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
  162. 2016-04-05 11:39:06.677 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
  163. 2016-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}
  164. 2016-04-05 11:39:06.687 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  165. 2016-04-05 11:39:06.690 +0900 [INFO] (0001:transaction): > 0.00 seconds
  166. 2016-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"
  167. 2016-04-05 11:39:06.695 +0900 [INFO] (0001:transaction): > 0.00 seconds (11 rows)
  168. 2016-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}
  169. 2016-04-05 11:39:06.736 +0900 [INFO] (0001:transaction): SQL: SET search_path TO "public"
  170. 2016-04-05 11:39:06.739 +0900 [INFO] (0001:transaction): > 0.00 seconds
  171. 2016-04-05 11:39:06.739 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp000"
  172. 2016-04-05 11:39:06.745 +0900 [INFO] (0001:transaction): > 0.01 seconds
  173. 2016-04-05 11:39:06.746 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp001"
  174. 2016-04-05 11:39:06.750 +0900 [INFO] (0001:transaction): > 0.00 seconds
  175. 2016-04-05 11:39:06.752 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp002"
  176. 2016-04-05 11:39:06.754 +0900 [INFO] (0001:transaction): > 0.00 seconds
  177. 2016-04-05 11:39:06.755 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS "account_buy_2aad4b00_bl_tmp003"
  178. 2016-04-05 11:39:06.757 +0900 [INFO] (0001:transaction): > 0.00 seconds
  179. 2016-04-05 11:39:06.761 +0900 [INFO] (main): Committed.
  180. 2016-04-05 11:39:06.762 +0900 [INFO] (main): Next config diff: {"in":{"last_path":"hoge.csv"},"out":{}}
  181. ```
  182.  
  183. ```
  184. embulk_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. ```
  206. 2016-04-05 11:40:43.675 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-mysql (0.5.1)
  207. 2016-04-05 11:40:43.748 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
  208. 2016-04-05 11:40:43.757 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
  209. 2016-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
  210. 2016-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}
  211. 2016-04-05 11:40:44.232 +0900 [INFO] (0001:transaction): Using insert mode
  212. 2016-04-05 11:40:44.239 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000`
  213. 2016-04-05 11:40:44.245 +0900 [INFO] (0001:transaction): > 0.01 seconds
  214. 2016-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)
  215. 2016-04-05 11:40:44.325 +0900 [INFO] (0001:transaction): > 0.06 seconds
  216. 2016-04-05 11:40:44.326 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001`
  217. 2016-04-05 11:40:44.327 +0900 [INFO] (0001:transaction): > 0.00 seconds
  218. 2016-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)
  219. 2016-04-05 11:40:44.371 +0900 [INFO] (0001:transaction): > 0.04 seconds
  220. 2016-04-05 11:40:44.372 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002`
  221. 2016-04-05 11:40:44.372 +0900 [INFO] (0001:transaction): > 0.00 seconds
  222. 2016-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)
  223. 2016-04-05 11:40:44.404 +0900 [INFO] (0001:transaction): > 0.03 seconds
  224. 2016-04-05 11:40:44.406 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003`
  225. 2016-04-05 11:40:44.408 +0900 [INFO] (0001:transaction): > 0.00 seconds
  226. 2016-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)
  227. 2016-04-05 11:40:44.442 +0900 [INFO] (0001:transaction): > 0.03 seconds
  228. 2016-04-05 11:40:44.519 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
  229. 2016-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}
  230. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  231. 2016-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}
  232. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  233. 2016-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}
  234. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  235. 2016-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}
  236. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  237. 2016-04-05 11:40:44.843 +0900 [INFO] (0017:task-0000): Loading 11 rows
  238. 2016-04-05 11:40:44.856 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
  239. 2016-04-05 11:40:44.857 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
  240. 2016-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}
  241. 2016-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)
  242. 2016-04-05 11:40:44.902 +0900 [INFO] (0001:transaction): > 0.03 seconds
  243. 2016-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`
  244. 2016-04-05 11:40:44.945 +0900 [INFO] (0001:transaction): > 0.04 seconds (11 rows)
  245. 2016-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}
  246. 2016-04-05 11:40:44.965 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp000`
  247. 2016-04-05 11:40:44.968 +0900 [INFO] (0001:transaction): > 0.00 seconds
  248. 2016-04-05 11:40:44.969 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp001`
  249. 2016-04-05 11:40:44.975 +0900 [INFO] (0001:transaction): > 0.01 seconds
  250. 2016-04-05 11:40:44.976 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp002`
  251. 2016-04-05 11:40:44.979 +0900 [INFO] (0001:transaction): > 0.00 seconds
  252. 2016-04-05 11:40:44.980 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570325ab2151a9c0_bl_tmp003`
  253. 2016-04-05 11:40:44.989 +0900 [INFO] (0001:transaction): > 0.01 seconds
  254. 2016-04-05 11:40:44.992 +0900 [INFO] (main): Committed.
  255. 2016-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
  261. CREATE 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. ```
  275. 2016-04-05 11:42:44.715 +0900: Embulk v0.8.8
  276. 2016-04-05 11:42:47.325 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-mysql (0.5.1)
  277. 2016-04-05 11:42:47.397 +0900 [INFO] (0001:transaction): Listing local files at directory '.' filtering filename by prefix 'hoge.csv'
  278. 2016-04-05 11:42:47.410 +0900 [INFO] (0001:transaction): Loading files [hoge.csv]
  279. 2016-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
  280. 2016-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}
  281. 2016-04-05 11:42:48.058 +0900 [INFO] (0001:transaction): Using insert mode
  282. 2016-04-05 11:42:48.080 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp000`
  283. 2016-04-05 11:42:48.086 +0900 [INFO] (0001:transaction): > 0.00 seconds
  284. 2016-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)
  285. 2016-04-05 11:42:48.140 +0900 [INFO] (0001:transaction): > 0.03 seconds
  286. 2016-04-05 11:42:48.141 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp001`
  287. 2016-04-05 11:42:48.142 +0900 [INFO] (0001:transaction): > 0.00 seconds
  288. 2016-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)
  289. 2016-04-05 11:42:48.169 +0900 [INFO] (0001:transaction): > 0.02 seconds
  290. 2016-04-05 11:42:48.169 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp002`
  291. 2016-04-05 11:42:48.170 +0900 [INFO] (0001:transaction): > 0.00 seconds
  292. 2016-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)
  293. 2016-04-05 11:42:48.198 +0900 [INFO] (0001:transaction): > 0.02 seconds
  294. 2016-04-05 11:42:48.199 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp003`
  295. 2016-04-05 11:42:48.200 +0900 [INFO] (0001:transaction): > 0.00 seconds
  296. 2016-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)
  297. 2016-04-05 11:42:48.231 +0900 [INFO] (0001:transaction): > 0.03 seconds
  298. 2016-04-05 11:42:48.280 +0900 [INFO] (0001:transaction): {done: 0 / 1, running: 0}
  299. 2016-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}
  300. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  301. 2016-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}
  302. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  303. 2016-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}
  304. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  305. 2016-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}
  306. 2016-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 (?, ?, ?, ?, ?, ?, ?, ?, ?)
  307. 2016-04-05 11:42:48.556 +0900 [INFO] (0017:task-0000): Loading 11 rows
  308. 2016-04-05 11:42:48.561 +0900 [INFO] (0017:task-0000): > 0.01 seconds (loaded 11 rows in total)
  309. 2016-04-05 11:42:48.562 +0900 [INFO] (0001:transaction): {done: 1 / 1, running: 0}
  310. 2016-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}
  311. 2016-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`
  312. 2016-04-05 11:42:48.577 +0900 [INFO] (0001:transaction): > 0.00 seconds (11 rows)
  313. 2016-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}
  314. 2016-04-05 11:42:48.595 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp000`
  315. 2016-04-05 11:42:48.598 +0900 [INFO] (0001:transaction): > 0.00 seconds
  316. 2016-04-05 11:42:48.598 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp001`
  317. 2016-04-05 11:42:48.606 +0900 [INFO] (0001:transaction): > 0.01 seconds
  318. 2016-04-05 11:42:48.607 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp002`
  319. 2016-04-05 11:42:48.611 +0900 [INFO] (0001:transaction): > 0.00 seconds
  320. 2016-04-05 11:42:48.611 +0900 [INFO] (0001:transaction): SQL: DROP TABLE IF EXISTS `account_buyertransaction_00000000570326270a408300_bl_tmp003`
  321. 2016-04-05 11:42:48.615 +0900 [INFO] (0001:transaction): > 0.00 seconds
  322. 2016-04-05 11:42:48.622 +0900 [INFO] (main): Committed.
  323. 2016-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. ```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!