13 #define LICENSE_REF_TABLE "ONLY license_ref"
16 long left,
long right,
long groupId,
17 bool ignoreIrre,
bool scanFindings) {
23 char* distinctPfile =
"SELECT DISTINCT pfile_fk FROM %s"
24 " WHERE upload_fk = $1 AND (ufile_mode&x'3C000000'::int) = 0 "
25 " AND (lft BETWEEN $2 AND $3) AND pfile_fk != 0";
26 char* distinctPfileNoDec =
"SELECT DISTINCT pfile_fk FROM ("
27 "SELECT distinct ON(ut.uploadtree_pk, ut.pfile_fk, scopesort) ut.pfile_fk pfile_fk, ut.uploadtree_pk, decision_type,"
28 " CASE cd.scope WHEN 1 THEN 1 ELSE 0 END AS scopesort"
30 " LEFT JOIN clearing_decision cd ON "
31 " ((ut.uploadtree_pk = cd.uploadtree_fk AND scope = 0 AND cd.group_fk = $5) "
32 " OR (ut.pfile_fk = cd.pfile_fk AND scope = 1)) "
33 " WHERE upload_fk=$1 AND (ufile_mode&x'3C000000'::int)=0 AND (lft BETWEEN $2 AND $3) AND ut.pfile_fk != 0"
34 " ORDER BY ut.uploadtree_pk, scopesort, ut.pfile_fk, clearing_decision_pk DESC"
35 ") itemView WHERE decision_type!=$4 OR decision_type IS NULL";
36 char* nonVoidPfile =
"SELECT pfile_fk FROM allPfileData"
37 " WHERE pfile_fk NOT IN (SELECT pfile_fk FROM license_file WHERE rf_fk IN"
38 " (SELECT rf_pk FROM " LICENSE_REF_TABLE
39 " WHERE rf_shortname = ANY(VALUES('No_license_found'), ('Void'))))";
41 if (!ignoreIrre && !scanFindings)
43 sql = g_strdup_printf(distinctPfile, tablename);
44 stmt = g_strdup_printf(
"queryFileIdsForUploadAndLimits.%s", tablename);
46 fo_dbManager_PrepareStamement(
54 else if(!ignoreIrre && scanFindings)
56 sql = g_strdup_printf(
57 g_strconcat(
"WITH allPfileData AS (", distinctPfile,
") ", nonVoidPfile,
59 stmt = g_strdup_printf(
"queryFileIdsForUploadAndLimitswithlicensefinding.%s", tablename);
61 fo_dbManager_PrepareStamement(
69 else if(ignoreIrre && scanFindings)
71 sql = g_strdup_printf(
72 g_strconcat(
"WITH allPfileData AS (", distinctPfileNoDec,
") ",
73 nonVoidPfile, NULL), tablename);
74 stmt = g_strdup_printf(
"queryFileIdsForUploadAndLimits.%s.ignoreirreandscanFindings", tablename);
76 fo_dbManager_PrepareStamement(
80 int,
long,
long,
int,
long),
81 uploadId, left, right, DECISION_TYPE_FOR_IRRELEVANT, groupId
86 sql = g_strdup_printf(distinctPfileNoDec, tablename);
87 stmt = g_strdup_printf(
"queryFileIdsForUploadAndLimits.%s.ignoreirre", tablename);
89 fo_dbManager_PrepareStamement(
93 int,
long,
long,
int,
long),
94 uploadId, left, right, DECISION_TYPE_FOR_IRRELEVANT, groupId
103 return fo_dbManager_Exec_printf(
105 "select rf_pk, rf_shortname from " LICENSE_REF_TABLE
" where rf_detector_type = 1 and rf_active = 'true'"
111 fo_dbManager_PrepareStamement(
113 "getLicenseTextForLicenseRefId",
114 "select rf_text from " LICENSE_REF_TABLE
" where rf_pk = $1",
119 if (PQntuples(licenseTextResult) != 1) {
120 printf(
"cannot find license text!\n");
121 PQclear(licenseTextResult);
125 char* result = g_strdup(PQgetvalue(licenseTextResult, 0, 0));
126 PQclear(licenseTextResult);
132 fo_dbManager_PrepareStamement(
134 "hasAlreadyResultsFor",
135 "SELECT 1 WHERE EXISTS (SELECT 1"
136 " FROM license_file WHERE agent_fk = $1 AND pfile_fk = $2"
144 exists = (PQntuples(insertResult) == 1);
145 PQclear(insertResult);
153 fo_dbManager_PrepareStamement(
156 "insert into license_file(agent_fk, pfile_fk) values($1,$2)",
164 PQclear(insertResult);
172 fo_dbManager_PrepareStamement(
175 "insert into license_file(rf_fk, agent_fk, pfile_fk, rf_match_pct) values($1,$2,$3,$4) RETURNING fl_pk",
176 long,
int,
long,
unsigned),
177 refId, agentId, pFileId, percent
180 long licenseFilePk = -1;
182 if (PQntuples(insertResult) == 1) {
183 licenseFilePk = atol(PQgetvalue(insertResult, 0, 0));
185 PQclear(insertResult);
188 return licenseFilePk;
193 fo_dbManager_PrepareStamement(
195 "saveDiffHighlightToDb",
196 "insert into highlight(fl_fk, type, start, len, rf_start, rf_len) values($1,$2,$3,$4,$5,$6)",
197 long,
char*,
size_t,
size_t,
size_t,
size_t),
200 diffInfo->text.start, diffInfo->text.length,
201 diffInfo->search.start, diffInfo->search.length
207 PQclear(insertResult);
213 size_t matchedInfoLen = matchedInfo->len ;
214 for (
size_t i = 0; i < matchedInfoLen; i++) {
216 if (!saveDiffHighlightToDb(
dbManager, diffMatchInfo, licenseFileId))
char * getUploadTreeTableName(fo_dbManager *dbManager, int uploadId)
Get the upload tree table name for a given upload.
fo_dbManager * dbManager
fo_dbManager object
PGresult * fo_dbManager_ExecPrepared(fo_dbManager_PreparedStatement *preparedStatement,...)
Execute a prepared statement.
int exists
Default not exists.