Golang连接Oracle数据库两种方式

Golang连接Oracle 需要安装Oracle Full Client或Instant Client 驱动程序

Linux安装Golang Oracle数据库驱动程序

MacBook安装Golang Oracle数据库驱动程序

方式一

使用go get github.com/mattn/go-oci8

在GoPath的src目录下创建oracleoci8.go,内容如下:

1. package main
3. import(
4. "database/sql"
5. "fmt"
6. _ "github.com/mattn/go-oci8"
7. "log"
8. "os"
9. )
11. func main(){
12. if len(os.Args)!=2{
13. log.Fatalln(os.Args[0]+" user/password@host:port/sid")
14. }
15. fmt.Println(os.Args[1])
17. db, err := sql.Open("oci8", os.Args[1])
19. if err !=nil{
20. log.Fatalln(err)
21. }
22. defer db.Close()
23. //查询用户
24. rows, err := db.Query("select user from dual")
25. if err !=nil{
26. log.Fatalln(err)
27. }
28. defer rows.Close()
29. for rows.Next(){
30. var data string
31. rows.Scan(&data)
32. fmt.Println(data)
33. }
34. if err = rows.Err(); err !=nil{
35. log.Fatalln(err)
36. }
37. //查询ZHUJI表的code字段
38. rows2, err := db.Query("SELECT code FROM ZHUJI")
39. if err !=nil{
40. log.Fatalln(err)
41. }
42. defer rows2.Close()
43. for rows2.Next(){
44. var data string
45. rows2.Scan(&data)
46. fmt.Println(data)
47. }
48. if err = rows2.Err(); err !=nil{
49. log.Fatalln(err)
50. }
51. }

运行

1. #直接运行
2. go run oracleoci8.go liang/liang@192.168.0.4:1521/orcl
3. #或者先编译成二进制,在运行二进制文件
4. go build oracleoci8.go
5. ./oracleoci8 liang/liang@192.168.0.4:1521/orcl

方式二

使用go get github.com/godror/godror

在GoPath的src目录下创建oracledror.go,内容如下:

1. package main
3. import(
4. "database/sql"
5. "encoding/json"
6. "fmt"
7. _ "github.com/godror/godror"
8. )
10. func main(){
11. db, err := sql.Open("godror",`user="liang" password="liang" connectString="192.168.0.4:1521/orcl"`)
12. if err !=nil{
13. panic(err)
14. }
15. err = db.Ping()
16. if err !=nil{
17. panic(err)
18. }
19. //查询ZHUJI表中code='pt'的sql:SELECT * FROM ZHUJI where CODE = 'pt'
20. sqlStatement :="SELECT * FROM ZHUJI where CODE = :1"
21. stmt, err := db.Prepare(sqlStatement)
22. defer stmt.Close()
23. if err !=nil{
24. panic(err)
25. }
26. rows, err := stmt.Query("pt")//输入sql中对应参数的值
27. if err !=nil{
28. panic(err)
29. }
31. defer rows.Close()//defer关闭查询连接
32. //获取列相关信息
33. strings, _ := rows.Columns()
35. for i :=0; i < len(strings); i++{
36. fmt.Print(" ", strings[i])
37. }
38. fmt.Print("\n")
39. //构造切片存储json
40. var slice []map[string]interface{}
41. var m1 map[string]interface{}
42. m1 = make(map[string]interface{})
44. var CODE, OVALUE1, OVALUE2 string
45. for rows.Next(){
46. rows.Scan(&CODE,&OVALUE1,&OVALUE2)//写入查询数据集的所有列名称
47. fmt.Printf("code is %s, OVALUE1 is %s\n", CODE, OVALUE1)
48. m1["CODE"]= CODE
49. m1["OVALUE1"]= OVALUE1
50. m1["OVALUE2"]= OVALUE2
51. slice = append(slice, m1)//分片中追加信息
52. }
53. if err = rows.Err(); err !=nil{
54. // handle the error here
55. }
56. defer stmt.Close()
58. data, err := json.Marshal(slice)
59. if err !=nil{
60. fmt.Printf("序列化错误 err = %v\n", err)
61. }
62. //输出序列化后的结果 json字符串
63. fmt.Printf("序列化后 = %v\n",string(data))
64. }

运行

1. #直接运行
2. go run oracledror.go
3. #或者先编译成二进制,在运行二进制文件
4. go build oracledror.go
5. ./oracledror

<audio controls="controls" style="display: none;"></audio>