aboutsummaryrefslogtreecommitdiff
path: root/dbstore/dbstore.go
diff options
context:
space:
mode:
authorPaul Duncan <pabs@pablotron.org>2022-02-17 23:42:11 -0500
committerPaul Duncan <pabs@pablotron.org>2022-02-17 23:42:11 -0500
commitd3ae0601b33a6cb73301e664dd1cceb2faf96df3 (patch)
treef7bb2d9df91b8b412dd14c087be77aab3f027404 /dbstore/dbstore.go
parent4188056a716add27a5d44b045e28c14ffa933eb0 (diff)
downloadcvez-d3ae0601b33a6cb73301e664dd1cceb2faf96df3.tar.bz2
cvez-d3ae0601b33a6cb73301e664dd1cceb2faf96df3.zip
dbstore: add DbStore#CpeMatchSearch() and backing query
Diffstat (limited to 'dbstore/dbstore.go')
-rw-r--r--dbstore/dbstore.go65
1 files changed, 60 insertions, 5 deletions
diff --git a/dbstore/dbstore.go b/dbstore/dbstore.go
index acaad7c..d30d0a8 100644
--- a/dbstore/dbstore.go
+++ b/dbstore/dbstore.go
@@ -232,11 +232,11 @@ func (me DbStore) CpeSearch(
// query IDs used by AddCpeMatches()
var addCpeMatchesQueryIds = []string {
- "cpe-match-insert",
- "cpe-match-insert-vulnerability",
- "cpe-match-insert-version-min",
- "cpe-match-insert-version-max",
- "cpe-match-insert-cpe",
+ "cpe-match/insert",
+ "cpe-match/insert-vulnerability",
+ "cpe-match/insert-version-min",
+ "cpe-match/insert-version-max",
+ "cpe-match/insert-name",
}
// import CPE matches
@@ -329,3 +329,58 @@ func (me DbStore) AddCpeMatches(ctx context.Context, matches cpematch.Matches) e
// commit changes, return result
return tx.Commit()
}
+
+// search CPE matches
+func (me DbStore) CpeMatchSearch(
+ ctx context.Context,
+ match string,
+) ([]string, error) {
+ var r []string
+
+ // lazy-init db
+ if err := me.Init(ctx); err != nil {
+ return r, err
+ }
+
+ // get query
+ // FIXME: cache this?
+ sql, err := getQuery("cpe-match/search.sql")
+ if err != nil {
+ return r, err
+ }
+
+ // exec search query
+ rows, err := me.db.QueryContext(ctx, sql, match)
+ if err != nil {
+ return r, err
+ }
+
+ // walk results
+ for rows.Next() {
+ var s string
+ if err := rows.Scan(&s); err != nil {
+ // return error
+ return r, err
+ } else {
+ // append to results
+ r = append(r, s)
+ }
+ }
+
+ // close rows
+ // FIXME: is this correct? i am following the example from the
+ // database/sql documentation, but it is messy and it seems
+ // counterintuitive to close the row set and then do an additional
+ // test for iteration errors...
+ if err = rows.Close(); err != nil {
+ return r, err
+ }
+
+ // check for iteration errors
+ if err = rows.Err(); err != nil {
+ return r, err
+ }
+
+ // return success
+ return r, nil
+}