Nell’articolo di oggi vedremo come integrare un database oracle e come effettuare le operazione di lettua e scrittura.<\/p>\n\n\n\n
Prima di tutto introduciamo il package per la gestione del db database\/sql e insieme al package dobbiamo importare il driver specifico per il database cui connettersi. L’elenco dei driver disponibili e le relative basi di dati supportati sono disponibili al link https:\/\/github.com\/golang\/go\/wiki\/SQLDrivers<\/a>. Per lavoro uso Oracle, pertanto nell’esempio integro il driver godror. Per poter usare questo driver occorre installarlo e configurarlo nell’ambiente go tramite la direttiva:<\/p>\n\n\n\n Il driver \u00e8 realizzato in cgo pertanto \u00e8 richiesta la presenza di un gcc compiler, nel mio caso ho utilizzato quello disponibile all’indirizzo https:\/\/jmeubank.github.io\/tdm-gcc\/<\/a>. Maggiori informazioni su godror sono disponibili al l’url https:\/\/github.com\/godror\/godror<\/a><\/p>\n\n\n\n Dopo aver installato gcc e godror possiamo finalmente definire l’import<\/p>\n\n\n\n Per la connessione al db il comando da usare \u00e8 Open del package db<\/p>\n\n\n\n Il primo parametro della Open \u00e8 il nome del driver e a seguire la stringa di connessione verso il db nel formato username@password@ip:port:sid<\/p>\n\n\n\n La funzione restituisce una istanza db e come secondo parametro un oggetto error che potr\u00e0 essere gestito tramite la funzione panic.<\/p>\n\n\n\n Vediamo subito come effettuare una operazione di scrittura tramite la funzione Exec<\/p>\n\n\n\n Nell’esempio tramite la funzione Begin ho avviato una transazione con commit previsto a fine operazioni di scrittura. Nel caso specifico sto facendo la cancellazione di un record dalla tabella di audit e successivo inserimento La funzione Exec ritorna un oggetto Result che rappresenta l’esito di una qualsiasi chiamata al db mostrando quante righe sono state coinvolte e l’id dell’ultimo inserimento.<\/p>\n\n\n\n Se volessi leggere i dati mi viene in aiuto la funzione Query che restituisce un cursore che scorre sulle righe selezionate<\/p>\n\n\n\n Nell’esempio sto leggenda dalla tabella audit tutti i record e tramite la funzione Scan dell’oggetto Rows la assegna a delle variabili per stamparne successivamente il valore. Con il comando defer chiudo il cursore alla fine di tutte le operazioni.<\/p>\n\n\n\n Per semplificare il lavoro con il db ci vengono in soccorso altri package che consentono di velocizzare il lavoro. Oggi introduco il package sqlx disponibile all’url https:\/\/jmoiron.github.io\/sqlx\/<\/a><\/p>\n\n\n\n Per installarlo il comando \u00e8<\/p>\n\n\n\n ad installazione effettuata pu\u00f2 essere importato con la direttiva github.com\/jmoiron\/sqlx”. Questo package consente di mappare le query direttamente su struct senza dover ricorrere al comando Scan.<\/p>\n\n\n\n Ho definito una struct Audit che presenta i parametri ID e dataora, ne ho definito il tipo e tramite il thick ho definito il mapping, tramite la regola del contesto:nomecolonna.<\/p>\n\n\n\n A questo punto ottengo il gioco \u00e8 fatto<\/p>\n\n\n\n Con la Open ottengo un riferimento al db che mi espone le funzioni Get per il recupero del singolo oggetto e Select per il recupero di un set di righe,<\/p>\n\n\n\n Alla prossima<\/p>\n\n\n\n ps. per i pigri a seguire l’intero codice<\/p>\n\n\n\n Nell’articolo di oggi vedremo come integrare un database oracle e come effettuare le operazione di lettua e scrittura. Prima di tutto introduciamo il package per la gestione del db database\/sql e insieme al package dobbiamo importare il driver specifico per il database cui connettersi. L’elenco dei driver disponibili e le relative basi di dati supportati … Continua la lettura di TUTORIAL GO – GESTIONE DEL DATABASE<\/span> go get github.com\/godror\/godror<\/pre>\n\n\n\n
import (\n\t\"database\/sql\"\n\t\"fmt\"\n\t_ \"github.com\/godror\/godror\"\n)<\/pre>\n\n\n\n
\tdb, err := sql.Open(\"godror\", \"ldc\/ldc@localhost:1521\/xe\")\n\tif err != nil {\n\t\tpanic(err)\n\t}<\/pre>\n\n\n\n\ttx, _ := db.Begin()\n\trowsDeleted, err := db.Exec(\"delete from audit_obj where id=1\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(\"rowsDeleted: \", rowsDeleted)\n\n\trowsInserted, err := db.Exec(\"insert into audit_obj (id, dataora, operazione) values(1, sysdate, 'insert')\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(\"rowsInserted: \", rowsInserted)\n\ttx.Commit()<\/pre>\n\n\n\n\trows, err := db.Query(\"select id, dataora, operazione from audit_obj\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tdefer rows.Close()\n\n\tvar id int\n\tvar dataora time.Time\n\tvar operazione string\n\tfor rows.Next() {\n\t\trows.Scan(&id, &dataora, &operazione)\n\t\tfmt.Println(id, dataora, operazione)\n\t}\n\tdb.Close()<\/pre>\n\n\n\ngo get github.com\/jmoiron\/sqlx<\/pre>\n\n\n\n
type Audit struct {\n\tID uint64 `db:\"ID\"`\n\tDATAORA time.Time `db:\"DATAORA\"`\n}<\/pre>\n\n\n\n\tdbx, err := sqlx.Open(\"godror\", \"ldc\/ldc@localhost:1521\/xe\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\n\tvar audit Audit\n\terr = dbx.Get(&audit, \"select id, dataora from audit_obj where id = 1\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(audit)\n\n\taudits := []Audit{}\n\tdbx.Select(&audits, \"select id, dataora from audit_obj\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(audits)<\/pre>\n\n\n\npackage main\n\nimport (\n\t\"database\/sql\"\n\t\"fmt\"\n\t\"time\"\n\n\t_ \"github.com\/godror\/godror\"\n\t\"github.com\/jmoiron\/sqlx\"\n)\n\ntype Audit struct {\n\tID uint64 `db:\"ID\"`\n\tDATAORA time.Time `db:\"DATAORA\"`\n}\n\nfunc main() {\n\n\tfmt.Println(\"Start\")\n\n\tdb, err := sql.Open(\"godror\", \"ldc\/ldc@localhost:1521\/xe\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\n\ttx, _ := db.Begin()\n\tresult, err := db.Exec(\"delete from audit_obj where id=1\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(\"rowsDeleted: \", result)\n\n\tresult, err = db.Exec(\"insert into audit_obj (id, dataora, operazione) values(1, sysdate, 'insert')\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(\"rowsInserted: \", result)\n\ttx.Commit()\n\n\trows, err := db.Query(\"select id, dataora, operazione from audit_obj\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tdefer rows.Close()\n\n\tvar id int\n\tvar dataora time.Time\n\tvar operazione string\n\tfor rows.Next() {\n\t\trows.Scan(&id, &dataora, &operazione)\n\t\tfmt.Println(id, dataora, operazione)\n\t}\n\tdb.Close()\n\n\tdbx, err := sqlx.Open(\"godror\", \"ldc\/ldc@localhost:1521\/xe\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\n\tvar audit Audit\n\terr = dbx.Get(&audit, \"select id, dataora from audit_obj where id = 1\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(audit)\n\n\taudits := []Audit{}\n\tdbx.Select(&audits, \"select id, dataora from audit_obj\")\n\tif err != nil {\n\t\tpanic(err)\n\t}\n\tfmt.Println(audits)\n\n\tdbx.Close()\n\tfmt.Println(\"End\")\n\n}\n<\/pre>\n","protected":false},"excerpt":{"rendered":"