112 lines
5.0 KiB
Plaintext
112 lines
5.0 KiB
Plaintext
<cfsetting showdebugoutput="no" enablecfoutputonly="true">
|
|
<cfheader name="Content-Type" value="application/json; charset=utf-8">
|
|
|
|
<cfparam name="url.action" default="test">
|
|
|
|
<cfset result = {ok: false, error: "unknown action"}>
|
|
|
|
<cftry>
|
|
<cfif url.action EQ "test">
|
|
<cfquery name="q" datasource="baza">SELECT 1 as ok</cfquery>
|
|
<cfset result = {ok: true, message: "PostgreSQL connected"}>
|
|
|
|
<cfelseif url.action EQ "tables">
|
|
<cfquery name="q" datasource="baza">
|
|
SELECT table_name FROM information_schema.tables
|
|
WHERE table_schema = 'public' ORDER BY table_name
|
|
</cfquery>
|
|
<cfset tables = []>
|
|
<cfloop query="q"><cfset arrayAppend(tables, q.table_name)></cfloop>
|
|
<cfset result = {ok: true, tables: tables}>
|
|
|
|
<cfelseif url.action EQ "schema">
|
|
<cfset result = {ok: true, results: []}>
|
|
<cftry>
|
|
<cfquery datasource="baza">
|
|
CREATE TABLE IF NOT EXISTS documents (
|
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
filename TEXT NOT NULL, mime_type TEXT NOT NULL,
|
|
original_bytes BYTEA, parsed_text TEXT, elements_json JSONB,
|
|
status TEXT DEFAULT 'uploaded', error_message TEXT,
|
|
created_at TIMESTAMPTZ DEFAULT now()
|
|
)
|
|
</cfquery>
|
|
<cfset arrayAppend(result.results, "documents: OK")>
|
|
<cfcatch><cfset arrayAppend(result.results, "documents: " & cfcatch.message)></cfcatch>
|
|
</cftry>
|
|
<cftry>
|
|
<cfquery datasource="baza">
|
|
CREATE TABLE IF NOT EXISTS contracts (
|
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
number TEXT NOT NULL, client TEXT, date_signed DATE,
|
|
status TEXT DEFAULT 'active', created_at TIMESTAMPTZ DEFAULT now()
|
|
)
|
|
</cfquery>
|
|
<cfset arrayAppend(result.results, "contracts: OK")>
|
|
<cfcatch><cfset arrayAppend(result.results, "contracts: " & cfcatch.message)></cfcatch>
|
|
</cftry>
|
|
<cftry>
|
|
<cfquery datasource="baza">
|
|
CREATE TABLE IF NOT EXISTS supplements (
|
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
contract_id UUID REFERENCES contracts(id),
|
|
number TEXT, date_signed DATE, type TEXT DEFAULT 'initial',
|
|
document_id UUID REFERENCES documents(id),
|
|
created_at TIMESTAMPTZ DEFAULT now()
|
|
)
|
|
</cfquery>
|
|
<cfset arrayAppend(result.results, "supplements: OK")>
|
|
<cfcatch><cfset arrayAppend(result.results, "supplements: " & cfcatch.message)></cfcatch>
|
|
</cftry>
|
|
<cftry>
|
|
<cfquery datasource="baza">
|
|
CREATE TABLE IF NOT EXISTS spec_rows (
|
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
supplement_id UUID REFERENCES supplements(id),
|
|
row_num INTEGER, name TEXT, price NUMERIC, qty NUMERIC,
|
|
sum NUMERIC, date_start DATE, date_end DATE,
|
|
created_at TIMESTAMPTZ DEFAULT now()
|
|
)
|
|
</cfquery>
|
|
<cfset arrayAppend(result.results, "spec_rows: OK")>
|
|
<cfcatch><cfset arrayAppend(result.results, "spec_rows: " & cfcatch.message)></cfcatch>
|
|
</cftry>
|
|
<cftry>
|
|
<cfquery datasource="baza">
|
|
CREATE TABLE IF NOT EXISTS spec_history (
|
|
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
|
|
contract_id UUID REFERENCES contracts(id),
|
|
supplement_id UUID REFERENCES supplements(id),
|
|
row_num INTEGER, change_type TEXT NOT NULL,
|
|
old_values JSONB, new_values JSONB,
|
|
created_at TIMESTAMPTZ DEFAULT now()
|
|
)
|
|
</cfquery>
|
|
<cfset arrayAppend(result.results, "spec_history: OK")>
|
|
<cfcatch><cfset arrayAppend(result.results, "spec_history: " & cfcatch.message)></cfcatch>
|
|
</cftry>
|
|
|
|
<cfelseif url.action EQ "query" AND structKeyExists(url, "sql")>
|
|
<cfquery name="q" datasource="baza">#preserveSingleQuotes(url.sql)#</cfquery>
|
|
<cfset cols = q.getColumnNames()>
|
|
<cfset rows = []>
|
|
<cfloop query="q">
|
|
<cfset row = {}>
|
|
<cfloop array="#cols#" index="c"><cfset row[c] = q[c][q.currentRow]></cfloop>
|
|
<cfset arrayAppend(rows, row)>
|
|
</cfloop>
|
|
<cfset result = {ok: true, columns: cols, rows: rows, count: q.recordCount}>
|
|
|
|
<cfelseif url.action EQ "execute" AND cgi.request_method EQ "POST">
|
|
<cfset body = deserializeJSON(toString(getHttpRequestData().content))>
|
|
<cfquery datasource="baza">#preserveSingleQuotes(body.sql)#</cfquery>
|
|
<cfset result = {ok: true}>
|
|
</cfif>
|
|
|
|
<cfcatch>
|
|
<cfset result = {ok: false, error: cfcatch.message}>
|
|
</cfcatch>
|
|
</cftry>
|
|
|
|
<cfoutput>#serializeJSON(result)#</cfoutput>
|