luciano/babashka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

test script

Browse source
This commit is contained in:
Michiel Borkent 2020-05-07 09:46:05 +02:00
parent 08478d966e
commit 787c13b304
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
examples/pods/pod-babashka-hsqldb/test.clj
View file

@ -16,11 +16,12 @@
(defn query [stream q] (defn query [stream q]
(write stream {"op" "invoke" (write stream {"op" "invoke"
"var" "hsqldb.jdbc/execute!" "id" "1"
"var" "pod.babashka.hsqldb/execute!"
"args" (pr-str ["jdbc:hsqldb:mem:testdb;sql.syntax_mys=true" q])})) "args" (pr-str ["jdbc:hsqldb:mem:testdb;sql.syntax_mys=true" q])}))
(let [pb (ProcessBuilder. #_["lein" "run" "-m" "org.babashka.hsqldb"] (let [pb (ProcessBuilder. #_["lein" "run" "-m" "pod.babashka.hsqldb"]
["./hsqldb-babashka-plugin"]) ["./pod-babashka-hsqldb"])
_ (.redirectErrorStream pb true) _ (.redirectErrorStream pb true)
;; _ (.redirectOutput pb ProcessBuilder$Redirect/INHERIT) ;; _ (.redirectOutput pb ProcessBuilder$Redirect/INHERIT)
p (.start pb) p (.start pb)
@ -29,8 +30,7 @@
stdout (java.io.PushbackInputStream. stdout)] stdout (java.io.PushbackInputStream. stdout)]
(write stdin {"op" "describe"}) (write stdin {"op" "describe"})
(let [reply (read stdout)] (let [reply (read stdout)]
(println "format:" (String. (get reply "format"))) (println "format:" (String. (get reply "format")))) ;;=> edn
(println "vars:" (mapv bytes->string (get reply "vars")))) ;;=> edn
(query stdin ["create table foo ( foo int );"]) (query stdin ["create table foo ( foo int );"])
(let [reply (read stdout)] (let [reply (read stdout)]