1.模式Ocral
package main2
import (
"database/sql"
"fmt"
"net"
"time"
_ "github.com/aliyun/go-driver-ob"
)
func PingTCP(addr string) error {
conn, err := net.Dial("tcp", addr)
if err != nil {
return err
}
defer conn.Close()
conn.SetReadDeadline(time.Now().Add(4 * time.Second))
reply := make([]byte, 128)
_, err = conn.Read(reply)
return err
}
func openDb() ( *sql.DB, error){
addr := fmt.Sprintf("%s:%s@tcp(%s)/", "name", "password", "t1.oceanbase.aliyuncs.com:1521")
err := PingTCP("t1.oceanbase.aliyuncs.com:1521")
if err != nil {
return nil, err
}
db, err := sql.Open("oceanbase", addr)
if err != nil {
return nil, err
}
return db, nil
}
func getColums(table string, db *sql.DB) error {
sql := fmt.Sprintf("select COLUMN_NAME, DATA_TYPE from user_tab_columns where table_name = '%s'", table)
rows, err := db.Query(sql)
if err != nil {
fmt.Sprintf("db.Query %v", err)
return err
}
for rows.Next() {
var ColumnName string
var DataType string
err=rows.Scan(&ColumnName, &DataType)
fmt.Println("ColumnName:", ColumnName, "DataType:", DataType)
}
return err
}
func getData(table string, db *sql.DB) error {
sql := fmt.Sprintf("select * from %s where rownum<=2000", table)
rows, err := db.Query(sql)
if err != nil {
fmt.Sprintf("db.Raw(sql).Rows() %v", err)
return err
}
columns, err := rows.Columns()
if err != nil {
fmt.Sprintf("rows.Columns() %v", err)
return err
}
fmt.Println(columns)
count := len(columns)
for rows.Next() {
values := make([]interface{}, count)
valuePtrs := make([]interface{}, count)
for i := 0; i < count; i++ {
valuePtrs[i] = &values[i]
}
rows.Scan(valuePtrs...)
for i, col := range columns {
var v interface{}
val := values[i]
b, ok := val.([]byte)
if ok {
v = string(b)
} else {
v = val
}
fmt.Println("ColumnName:", col, "Data:", v)
}
}
return err
}
func listTable(db *sql.DB) error{
//var tbs []TableMeta
rows, err := db.Query("select TABLE_NAME,NUM_ROWS from user_tables")
if err != nil {
fmt.Println("select TABLE_NAME,NUM_ROWS from user_tables failed. ")
return err
}
for rows.Next() {
var TablesName string
var TablesRows int64
err=rows.Scan(&TablesName, &TablesRows)
fmt.Println("Tables name: ", TablesName)
fmt.Println("Tables Row: ", TablesRows)
getColums(TablesName,db)
getData(TablesName, db)
}
return nil
}
func main(){
db,err := openDb()
if err == nil {
listTable(db)
db.Close()
} else {
fmt.Println("open failed.")
}
}
2.模式Mysqlpackage main
import (
"database/sql"
"fmt"
"net"
"time"
_ "github.com/aliyun/go-driver-ob"
)
func PingTCP(addr string) error {
conn, err := net.Dial("tcp", addr)
if err != nil {
return err
}
defer conn.Close()
conn.SetReadDeadline(time.Now().Add(4 * time.Second))
reply := make([]byte, 128)
_, err = conn.Read(reply)
return err
}
func openDb() ( *sql.DB, error){
addr := fmt.Sprintf("%s:%s@tcp(%s)/sddptest02", "USER", "PASSWORD", "t12.oceanbase.aliyuncs.com:3306")
err := PingTCP("t12.oceanbase.aliyuncs.com:3306")
if err != nil {
return nil, err
}
db, err := sql.Open("oceanbase", addr)
if err != nil {
return nil, err
}
return db, nil
}
func getColums(table string, db *sql.DB) error {
sql := fmt.Sprintf("show columns from %s.%s", "sddptest02", table)
rows, err := db.Query(sql)
if err != nil {
fmt.Sprintf("db.Query %v", err)
return err
}
for rows.Next() {
var ColumnName string
var DataType string
var NullFlag string
var KeyFlag string
var DefaultFlag string
var ExtraFlag string
err=rows.Scan(&ColumnName, &DataType, &NullFlag, &KeyFlag, &DefaultFlag, &ExtraFlag)
fmt.Println("ColumnName:", ColumnName, "DataType:", DataType)
}
return err
}
func getData(table string, db *sql.DB) error {
sql := fmt.Sprintf("select * from %s limit 2000", table)
rows, err := db.Query(sql)
if err != nil {
fmt.Sprintf("db.Raw(sql).Rows() %v", err)
return err
}
columns, err := rows.Columns()
if err != nil {
fmt.Sprintf("rows.Columns() %v", err)
return err
}
fmt.Println(columns)
count := len(columns)
for rows.Next() {
values := make([]interface{}, count)
valuePtrs := make([]interface{}, count)
for i := 0; i < count; i++ {
valuePtrs[i] = &values[i]
}
rows.Scan(valuePtrs...)
for i, col := range columns {
var v interface{}
val := values[i]
b, ok := val.([]byte)
if ok {
v = string(b)
} else {
v = val
}
fmt.Println("ColumnName:", col, "Data:", v)
}
}
return err
}
func listTable(db *sql.DB) error{
//var tbs []TableMeta
rows, err := db.Query("show tables from sddptest02")
if err != nil {
fmt.Println("show tables. ")
return err
}
for rows.Next() {
var TablesName string
err=rows.Scan(&TablesName)
fmt.Println("Tables name: ", TablesName)
getColums(TablesName,db)
getData(TablesName, db)
}
return nil
}
func insertData(db *sql.DB) {
for i :=0; i< 200; i++ {
sql := fmt.Sprintf("insert into table1 (name,address) values ('zhangsan%d','beijing%d')", i, i)
if result, err := db.Exec(sql); err == nil {
if num, err := result.RowsAffected(); err == nil {
fmt.Println("insert row number : ", num);
} else {
fmt.Println("affected row number failed ", err)
}
} else {
fmt.Println("insert row number failed ", err)
}
}
}
func main(){
db,err := openDb()
if err == nil {
insertData(db)
listTable(db)
db.Close()
} else {
fmt.Println("open failed.")
}
}