storage/msglog: get-track working; next step: consequent use of keywords for keys and head values

This commit is contained in:
Helmut Merz 2024-07-28 14:46:49 +02:00
parent ac2ebf5fe7
commit 777660a957
3 changed files with 6 additions and 6 deletions

View file

@ -63,15 +63,11 @@
(defun query (st spec) (defun query (st spec)
(multiple-value-bind (sql args) (sxql:yield spec) (multiple-value-bind (sql args) (sxql:yield spec)
;(log:info "sql: ~s, args: ~s" sql args)
(let* ((qp (dbi:prepare (conn st) sql)) (let* ((qp (dbi:prepare (conn st) sql))
(qx (dbi:execute qp args))) (qx (dbi:execute qp args)))
(dbi:fetch-all qx)))) (dbi:fetch-all qx))))
(defun xdo-sql (st spec)
(multiple-value-bind (sql args) (sxql:yield spec)
;(print sql)
(dbi:do-sql (conn st) sql args)))
(defun do-sql (st spec) (defun do-sql (st spec)
(multiple-value-bind (sql args) (sxql:yield spec) (multiple-value-bind (sql args) (sxql:yield spec)
(let* ((conn (conn st)) (let* ((conn (conn st))

View file

@ -72,6 +72,7 @@
(setup-track tr row))) (setup-track tr row)))
(defun setup-track (tr row) (defun setup-track (tr row)
;(log:info "tr: ~s, row: ~s" tr row)
(let ((hv (mapcar #'(lambda (x) (getf row x)) (shape:head-fields tr)))) (let ((hv (mapcar #'(lambda (x) (getf row x)) (shape:head-fields tr))))
(setf (shape:head tr) hv) (setf (shape:head tr) hv)
(setf (trackid tr) (getf row :trackid)) (setf (trackid tr) (getf row :trackid))

View file

@ -62,10 +62,13 @@
(deftest test-msglog (ctx) (deftest test-msglog (ctx)
(let ((st (storage:storage ctx)) (let ((st (storage:storage ctx))
(data (make-hash-table)) (data (make-hash-table))
cont msg pm) cont msg pm pm2)
(setf cont (msglog:make-container st)) (setf cont (msglog:make-container st))
(storage:drop-table st :messages) (storage:drop-table st :messages)
(tracking:create-table cont) (tracking:create-table cont)
(setf msg (message:create '(:test :data :field :info) :data '(:info "test data"))) (setf msg (message:create '(:test :data :field :info) :data '(:info "test data")))
(setf pm (msglog:save msg cont)) (setf pm (msglog:save msg cont))
(== (tracking:trackid pm) 1)
(setf pm2 (tracking:get-track cont 1))
(log:info "pm2: ~s" pm2)
)) ))