Blame view
tables_utility.go
2.91 KB
64041a2ea
first commit
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 |
package restutility
import (
"encoding/json"
"io"
"io/ioutil"
"errors"
"fmt"
"gopkg.in/rana/ora.v3"
)
type TableConfig struct {
Tables []Table
}
type Table struct {
TableType string `json:"tableType"`
Translations []TableTranslation `json:"translations"`
TableFields []Field `json:"tableFields"`
Correlations []CorrelationField `json:"correlation_fields"`
IdField string `json:"idField"`
}
type CorrelationField struct {
Result string `json:"result"`
Elements []string `json:"elements"`
Type string `json:"type"`
}
type TableTranslation struct {
Language string `json:"language"`
FieldsLabels map[string]string `json:"fieldsLabels"`
}
func (tl TableConfig) LoadTranslations(tableType string) LangMap {
translations := make(LangMap, 0)
for _, table := range tl.Tables {
if tableType == table.TableType {
for _, t := range table.Translations {
translations[t.Language] = t.FieldsLabels
}
}
}
return translations
}
func (tl TableConfig) LoadFields(tableType string) []Field {
fields := make([]Field, 0)
for _, table := range tl.Tables {
if tableType == table.TableType {
for _, f := range table.TableFields {
fields = append(fields, f)
}
}
}
return fields
}
func (tl TableConfig) LoadIdField(tableType string) string {
for _, table := range tl.Tables {
if tableType == table.TableType {
return table.IdField
}
}
return ""
}
func (tl TableConfig) LoadCorrelations(tableType string) []CorrelationField {
resp := make([]CorrelationField, 0)
for _, table := range tl.Tables {
if tableType == table.TableType {
for _, f := range table.Correlations {
resp = append(resp, f)
}
}
}
return resp
}
var _tables TableConfig
var _prevProject string
func getTablesConfigJSON(project string) error {
_prevProject = project
stmt, err := Oracle.Ses.Prep(`SELECT
JSON_CLOB
FROM TABLES_CONFIG
WHERE PROJEKAT` + project, ora.S)
defer stmt.Close()
if err != nil {
return err
}
rset, err := stmt.Qry()
if err != nil {
return err
}
if rset.Next() {
lob := rset.Row[0].(io.Reader)
bytes, err := ioutil.ReadAll(lob)
if err != nil {
fmt.Printf("mega error: %v
", err)
}
json.Unmarshal(bytes, &_tables.Tables)
}
return nil
}
func loadTablesConfig(project string) error {
err := getTablesConfigJSON(putQuotes(project))
//file, err := ioutil.ReadFile("./config/tables-config.json")
if err != nil {
fmt.Printf("%v
", err);
return errors.New("unable to load tables config")
}
//json.Unmarshal(file, &_TABLES_CONFIG.Tables)
if len(_TABLES_CONFIG.Tables) == 0 {
return errors.New("tables config is corrupt")
}
return nil
}
func loadTable(table string) JSONParams {
return NewJSONParams(_tables.LoadTranslations(table),
_tables.LoadFields(table),
_tables.LoadIdField(table),
_tables.LoadCorrelations(table))
}
func refreshTables() error {
return getTablesConfigJSON(_prevProject)
}
|