query.cljs 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. (ns query
  2. "An example script that queries any db graph from the commandline e.g.
  3. $ yarn -s nbb-logseq script/query.cljs db-name '[:find (pull ?b [:block/name :block/content]) :where [?b :block/created-at]]'"
  4. (:require [datascript.core :as d]
  5. [clojure.edn :as edn]
  6. [logseq.db.sqlite.db :as sqlite-db]
  7. [logseq.db.frontend.rules :as rules]
  8. [nbb.core :as nbb]
  9. [clojure.string :as string]
  10. ["path" :as node-path]
  11. ["os" :as os]))
  12. (defn- get-dir-and-db-name
  13. "Gets dir and db name for use with open-db!"
  14. [graph-dir]
  15. (if (string/includes? graph-dir "/")
  16. (let [graph-dir'
  17. (node-path/join (or js/process.env.ORIGINAL_PWD ".") graph-dir)]
  18. ((juxt node-path/dirname node-path/basename) graph-dir'))
  19. [(node-path/join (os/homedir) "logseq" "graphs") graph-dir]))
  20. (defn -main [args]
  21. (when (< (count args) 2)
  22. (println "Usage: $0 GRAPH QUERY")
  23. (js/process.exit 1))
  24. (let [[graph-dir query*] args
  25. [dir db-name] (get-dir-and-db-name graph-dir)
  26. conn (sqlite-db/open-db! dir db-name)
  27. results (if ((set args) "-e")
  28. (map #(when-let [ent (d/entity @conn (edn/read-string %))]
  29. (cond-> (into {:db/id (:db/id ent)} ent)
  30. (seq (:block/properties ent))
  31. (update :block/properties (fn [props] (map (fn [m] (into {} m)) props)))))
  32. (drop 2 args))
  33. ;; assumes no :in are in queries
  34. (let [query (into (edn/read-string query*) [:in '$ '%])
  35. res (d/q query @conn (rules/extract-rules rules/db-query-dsl-rules))]
  36. ;; Remove nesting for most queries which just have one :find binding
  37. (if (= 1 (count (first res))) (mapv first res) res)))]
  38. (when ((set args) "-v") (println "DB contains" (count (d/datoms @conn :eavt)) "datoms"))
  39. (prn results)))
  40. (when (= nbb/*file* (:file (meta #'-main)))
  41. (-main *command-line-args*))