XTDB version 2 を読みながらメモ

docker pull ghcr.io/xtdb/xtdb-standalone-ea

docker run -tip 3000:3000 ghcr.io/xtdb/xtdb-standalone-ea
Starting XTDB 2.x (pre-alpha) @ "dev-SNAPSHOT" @ 7ef8b33 ...
20:55:49 | INFO  xtdb.server | HTTP server started on port:  3000
20:55:49 | INFO  xtdb.cli | Node started
...

curl http://localhost:3000/status
{"latest-completed-tx":null,"latest-submitted-tx":null}

docker run \
  -tip 3000:3000 \
  -v /path/to/host/dir:/var/lib/xtdb \
  ghcr.io/xtdb/xtdb-standalone-ea

{:mvn/repos {"ossrh-snapshots" {:url "https://s01.oss.sonatype.org/content/repositories/snapshots"}}

 :deps {org.clojure/clojure {:mvn/version "1.11.1"}
        com.xtdb/xtdb-api {:mvn/version "2.0.0-SNAPSHOT"}
        com.xtdb/xtdb-http-client-clj {:mvn/version "2.0.0-SNAPSHOT"}}}

;; deps.edn があるディレクトリで
$ clj

user=> (require '[xtdb.client :as xtc]
         '[xtdb.api :as xt])

(with-open [node (xtc/start-client "http://localhost:3000")]
  (xt/status node))

user=> {:latest-completed-tx nil, :latest-submitted-tx nil}

git clone git@github.com:xtdb/sakila-playground.git
cd sakila-playground/

clj -M:xtdb:nrepl

Caused by: java.lang.UnsupportedClassVersionError: xtdb/IArrowWriter has been compiled by a more recent version of the Java Runtime (class file version 61.0), this version of the Java Runtime only recognizes class file versions up to 55.0

$ cat /etc/os-release 
NAME="Linux Mint"
VERSION="21.2 (Victoria)"

$ clj --version 
Clojure CLI version 1.11.1.1155

$ java -version
openjdk version "11.0.21" 2023-10-17

;; needed on JDK16+

# OpenJDKパッケージの利用可能なバージョンを確認する
apt search openjdk

# openjdk-xx-jdk で利用できる一番新しそうなのは、openjdk-21-jdk だったので、
sudo apt install openjdk-21-jdk
sudo apt install openjdk-21-jre # 念の為やってみたけど↑で最新にしてくれてた

clj -M:xtdb:nrepl
rlwrap: warning: could not set locale
warnings can be silenced by the --no-warnings (-n) option
17:37:06 | DEBUG user | Submitting 'actor' table
17:37:07 | DEBUG user | Submitting 'address' table
17:37:07 | DEBUG user | Submitting 'category' table
17:37:07 | DEBUG user | Submitting 'city' table
17:37:07 | DEBUG user | Submitting 'country' table
17:37:07 | DEBUG user | Submitting 'customer' table
17:37:07 | DEBUG user | Submitting 'film' table
17:37:07 | DEBUG user | Submitting 'film_actor' table
17:37:07 | DEBUG user | Submitting 'film_category' table
17:37:07 | DEBUG user | Submitting 'inventory' table
17:37:07 | DEBUG user | Submitting 'language' table
17:37:07 | DEBUG user | Submitting 'payment' table
17:37:07 | DEBUG user | Submitting 'rental' table
17:37:08 | DEBUG user | Submitting 'staff' table
17:37:08 | DEBUG user | Submitting 'store' table
17:37:08 | INFO  user | Sakila playground started!
nREPL server started on port 35497 on host localhost - nrepl://localhost:35497

(from :customer [first_name last_name])

(xt/q node クエリをクオートで渡す)

(xt/q xt-node 
        '(from :customer [first_name last_name]))

;;  [{:last-name "BROWN", :first-name "ELIZABETH"} 
;;  {:last-name "YOUNG", :first-name "CYNTHIA"} 
;;  {:last-name "BURKE", :first-name "LYDIA"} ..... 
;;  ]

(xt/q xt-node
      '(-> (from :customer [*])
           (limit 3)))
;;  [{:xt/valid-from #time/zoned-date-time "2023-12-26T10:44:13.640116Z[UTC]", :address-id 9, :email "ELIZABETH.BROWN@sakilacustomer.org", :last-name "BROWN", :store-id 1, :first-name "ELIZABETH", :active true, :xt/id 5} 
;;  {:xt/valid-from #time/zoned-date-time "2023-12-26T10:44:13.640116Z[UTC]", :address-id 32, :email "CYNTHIA.YOUNG@sakilacustomer.org", :last-name "YOUNG", :store-id 1, :first-name "CYNTHIA", :active true, :xt/id 28} 
;;  {:xt/valid-from #time/zoned-date-time "2023-12-26T10:44:13.640116Z[UTC]", :address-id 247, :email "LYDIA.BURKE@sakilacustomer.org", :last-name "BURKE", :store-id 1, :first-name "LYDIA", :active true, :xt/id 243}]

SELECT c.customer_name, o.xt$id AS order_id, o.order_value
FROM customers c
  JOIN orders o ON (o.customer_id = c.xt$id)

(-> (unify (from :customers [{:xt/id customer-id} customer-name])
           (from :orders [{:xt/id order-id} customer-id order-value]))
    (return customer-name order-id order-value))

{:email "MARY.SMITH@sakilacustomer.org", :first_name "MARY", :xt/valid-from #time/instant "2006-02-14T22:04:36Z", :active true, :last_name "SMITH", :address_id 5, :xt/id 1, :store_id 1}
{:email "PATRICIA.JOHNSON@sakilacustomer.org", :first_name "PATRICIA", :xt/valid-from #time/instant "2006-02-14T22:04:36Z", :active true, :last_name "JOHNSON", :address_id 6, :xt/id 2, :store_id 1}
{:email "LINDA.WILLIAMS@sakilacustomer.org", :first_name "LINDA", :xt/valid-from #time/instant "2006-02-14T22:04:36Z", :active true, :last_name "WILLIAMS", :address_id 7, :xt/id 3, :store_id 1}

{:address "47 MySakila Drive", :district "Alberta", :city_id 300, :xt/id 1}
{:address "28 MySQL Boulevard", :district "QLD", :city_id 576, :xt/id 2}
{:address "23 Workhaven Lane", :district "Alberta", :city_id 300, :phone "14033335568", :xt/id 3}

(xt/q xt-node
      '(-> (unify (from :customer [address-id first-name])
                  (from :address [{:xt/id address-id} district address]))
           (return first-name district)
           (order-by district)
           (limit 3)))

[{:first-name "TOM", :district "Abu Dhabi"} 
 {:first-name "LILLIAN", :district "Abu Dhabi"} 
 {:first-name "JORGE", :district "Aceh"} ]

(xt/put
 :person
 {:person/name "James Cameron",
  :person/born #inst "1954-08-16T00:00:00.000-00:00",
  :xt/id 100})

#xt.tx/put {:table-name :person, :doc {:person/name "James Cameron", :person/born #inst "1954-08-16T00:00:00.000-00:00", :xt/id 100}, :valid-from nil, :valid-to nil}

(def my-node (xtn/start-node {}))

(xt/submit-tx 
 my-node
 [(xt/put :person
        {:person/name "James Cameron",
         :person/born #inst "1954-08-16T00:00:00.000-00:00",
         :xt/id 100})])

;; #xt/tx-key {:tx-id 0, :system-time #time/instant "2023-12-31T08:28:27.838133Z"}

(xt/q my-node '(from :person [*]))
;; [{:person/born #time/zoned-date-time "1954-08-16T00:00Z[UTC]", :person/name "James Cameron", :xt/id 100}]

  (def my-node (xtn/start-node {}))
  
  (xt/submit-tx
   my-node
   [(xt/put :person
            {:person/name "James Cameron",
             :person/born #inst "1954-08-16T00:00:00.000-00:00",
             :xt/id 100})]
   {:system-time #inst "2018-06-01"}) ;; :default-tz  は説明書もテストも見つからず
;; #xt/tx-key {:tx-id 0, :system-time #time/instant "2018-06-01T00:00:00Z"}

  (xt/submit-tx
   my-node
   (for [doc my-persons]
     (xt/put :persons doc)))
  (xt/submit-tx
   my-node
   (for [doc my-movies]
     (xt/put :movies doc))

(xt/q my-node
      '(-> (from :movies [movie/title movie/year])
           (limit 3)))
;; [#:movie{:year 1986, :title "Aliens"} #:movie{:year 1988, :title "Die Hard"} #:movie{:year 1988, :title "Rambo III"}]