golang利用oci8库访问Oracle数据库

CodingCode · · 1057 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

golang利用oci8库访问Oracle数据库例子。

package main

import (
    "fmt"
    "log"
    "database/sql"

  _ "github.com/mattn/go-oci8"
)


func sqlExec(db *sql.DB, sqlStmt string) error {
    res, err := db.Exec(sqlStmt)
    if err != nil {
        return err
    }

    num, err := res.RowsAffected()
    if err != nil {
        return err
    }

    log.Printf("SQL Execute success rows affected %d\n", num)
    return nil
}

func sqlQuery(db *sql.DB, sqlStmt string) error {
    rows, err := db.Query(sqlStmt)
    if err != nil {
        return err
    }
    defer rows.Close()

    var n int 
    for rows.Next() {
        var name string
        var age int 
        if err := rows.Scan(&name, &age); err != nil {
            return err
        }
        n ++
        log.Printf("row[%d], name=[%s], age=[%d]\n", n, name, age)
    }

    err = rows.Err()
    if err != nil {
        return err
    }

    log.Printf("SQL Query success rows queried %d\n", n)
    return nil
}

func main() {
    db, err := sql.Open("oci8", fmt.Sprintf("%s/%s@%s", "scott", "tiger", "bej301420.cn.oracle.com:1522/orcl.cn.oracle.com"))
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    if err := db.Ping(); err != nil {
        log.Fatal(err)
    }


    if err := sqlExec(db, "create table mytest(name varchar2(10), age int, primary key(name))"); err != nil {
        log.Fatal(err)
    }
    
    if err := sqlExec(db, "insert into mytest(name, age) values('Tom', 20)"); err != nil {
        log.Fatal(err)
    }

    if err := sqlExec(db, "insert into mytest(name, age) values('Jerry', 20)"); err != nil {
        log.Fatal(err)
    }
    if err := sqlQuery(db, "select name, age from mytest"); err != nil {
        log.Fatal(err)
    }

    if err := sqlExec(db, "drop table mytest"); err != nil {
        log.Fatal(err)
    }
}

运行结果如下:

2019/01/19 12:19:36 SQL Execute success rows affected 0
2019/01/19 12:19:36 SQL Execute success rows affected 1
2019/01/19 12:19:36 SQL Execute success rows affected 1
2019/01/19 12:19:36 row[1], name=[Tom], age=[20]
2019/01/19 12:19:36 row[2], name=[Jerry], age=[20]
2019/01/19 12:19:36 SQL Query success rows queried 2
2019/01/19 12:19:36 SQL Execute success rows affected 0

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:CodingCode

查看原文:golang利用oci8库访问Oracle数据库

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1057 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传