dos2unix format
This commit is contained in:
Lunny Xiao
parent
a70053a60d
commit
fbb52b27eb
516
oracle.go
516
oracle.go
|
|
@ -1,258 +1,258 @@
|
||||||
package xorm
|
package xorm
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"regexp"
|
"regexp"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
type oracle struct {
|
type oracle struct {
|
||||||
base
|
base
|
||||||
}
|
}
|
||||||
|
|
||||||
type oracleParser struct {
|
type oracleParser struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
//dataSourceName=user/password@ipv4:port/dbname
|
//dataSourceName=user/password@ipv4:port/dbname
|
||||||
//dataSourceName=user/password@[ipv6]:port/dbname
|
//dataSourceName=user/password@[ipv6]:port/dbname
|
||||||
func (p *oracleParser) parse(driverName, dataSourceName string) (*uri, error) {
|
func (p *oracleParser) parse(driverName, dataSourceName string) (*uri, error) {
|
||||||
db := &uri{dbType: ORACLE_OCI}
|
db := &uri{dbType: ORACLE_OCI}
|
||||||
dsnPattern := regexp.MustCompile(
|
dsnPattern := regexp.MustCompile(
|
||||||
`^(?P<user>.*)\/(?P<password>.*)@` + // user:password@
|
`^(?P<user>.*)\/(?P<password>.*)@` + // user:password@
|
||||||
`(?P<net>.*)` + // ip:port
|
`(?P<net>.*)` + // ip:port
|
||||||
`\/(?P<dbname>.*)`) // dbname
|
`\/(?P<dbname>.*)`) // dbname
|
||||||
matches := dsnPattern.FindStringSubmatch(dataSourceName)
|
matches := dsnPattern.FindStringSubmatch(dataSourceName)
|
||||||
names := dsnPattern.SubexpNames()
|
names := dsnPattern.SubexpNames()
|
||||||
for i, match := range matches {
|
for i, match := range matches {
|
||||||
switch names[i] {
|
switch names[i] {
|
||||||
case "dbname":
|
case "dbname":
|
||||||
db.dbName = match
|
db.dbName = match
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if db.dbName == "" {
|
if db.dbName == "" {
|
||||||
return nil, errors.New("dbname is empty")
|
return nil, errors.New("dbname is empty")
|
||||||
}
|
}
|
||||||
return db, nil
|
return db, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) Init(drivername, uri string) error {
|
func (db *oracle) Init(drivername, uri string) error {
|
||||||
return db.base.init(&oracleParser{}, drivername, uri)
|
return db.base.init(&oracleParser{}, drivername, uri)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) SqlType(c *Column) string {
|
func (db *oracle) SqlType(c *Column) string {
|
||||||
var res string
|
var res string
|
||||||
switch t := c.SQLType.Name; t {
|
switch t := c.SQLType.Name; t {
|
||||||
case Bit, TinyInt, SmallInt, MediumInt, Int, Integer, BigInt, Bool, Serial, BigSerial:
|
case Bit, TinyInt, SmallInt, MediumInt, Int, Integer, BigInt, Bool, Serial, BigSerial:
|
||||||
return "NUMBER"
|
return "NUMBER"
|
||||||
case Binary, VarBinary, Blob, TinyBlob, MediumBlob, LongBlob, Bytea:
|
case Binary, VarBinary, Blob, TinyBlob, MediumBlob, LongBlob, Bytea:
|
||||||
return Blob
|
return Blob
|
||||||
case Time, DateTime, TimeStamp:
|
case Time, DateTime, TimeStamp:
|
||||||
res = TimeStamp
|
res = TimeStamp
|
||||||
case TimeStampz:
|
case TimeStampz:
|
||||||
res = "TIMESTAMP WITH TIME ZONE"
|
res = "TIMESTAMP WITH TIME ZONE"
|
||||||
case Float, Double, Numeric, Decimal:
|
case Float, Double, Numeric, Decimal:
|
||||||
res = "NUMBER"
|
res = "NUMBER"
|
||||||
case Text, MediumText, LongText:
|
case Text, MediumText, LongText:
|
||||||
res = "CLOB"
|
res = "CLOB"
|
||||||
case Char, Varchar, TinyText:
|
case Char, Varchar, TinyText:
|
||||||
return "VARCHAR2"
|
return "VARCHAR2"
|
||||||
default:
|
default:
|
||||||
res = t
|
res = t
|
||||||
}
|
}
|
||||||
|
|
||||||
var hasLen1 bool = (c.Length > 0)
|
var hasLen1 bool = (c.Length > 0)
|
||||||
var hasLen2 bool = (c.Length2 > 0)
|
var hasLen2 bool = (c.Length2 > 0)
|
||||||
if hasLen1 {
|
if hasLen1 {
|
||||||
res += "(" + strconv.Itoa(c.Length) + ")"
|
res += "(" + strconv.Itoa(c.Length) + ")"
|
||||||
} else if hasLen2 {
|
} else if hasLen2 {
|
||||||
res += "(" + strconv.Itoa(c.Length) + "," + strconv.Itoa(c.Length2) + ")"
|
res += "(" + strconv.Itoa(c.Length) + "," + strconv.Itoa(c.Length2) + ")"
|
||||||
}
|
}
|
||||||
return res
|
return res
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) SupportInsertMany() bool {
|
func (db *oracle) SupportInsertMany() bool {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) QuoteStr() string {
|
func (db *oracle) QuoteStr() string {
|
||||||
return "\""
|
return "\""
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) AutoIncrStr() string {
|
func (db *oracle) AutoIncrStr() string {
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) SupportEngine() bool {
|
func (db *oracle) SupportEngine() bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) SupportCharset() bool {
|
func (db *oracle) SupportCharset() bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) IndexOnTable() bool {
|
func (db *oracle) IndexOnTable() bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) IndexCheckSql(tableName, idxName string) (string, []interface{}) {
|
func (db *oracle) IndexCheckSql(tableName, idxName string) (string, []interface{}) {
|
||||||
args := []interface{}{strings.ToUpper(tableName), strings.ToUpper(idxName)}
|
args := []interface{}{strings.ToUpper(tableName), strings.ToUpper(idxName)}
|
||||||
return `SELECT INDEX_NAME FROM USER_INDEXES ` +
|
return `SELECT INDEX_NAME FROM USER_INDEXES ` +
|
||||||
`WHERE TABLE_NAME = ? AND INDEX_NAME = ?`, args
|
`WHERE TABLE_NAME = ? AND INDEX_NAME = ?`, args
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) TableCheckSql(tableName string) (string, []interface{}) {
|
func (db *oracle) TableCheckSql(tableName string) (string, []interface{}) {
|
||||||
args := []interface{}{strings.ToUpper(tableName)}
|
args := []interface{}{strings.ToUpper(tableName)}
|
||||||
return `SELECT table_name FROM user_tables WHERE table_name = ?`, args
|
return `SELECT table_name FROM user_tables WHERE table_name = ?`, args
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) ColumnCheckSql(tableName, colName string) (string, []interface{}) {
|
func (db *oracle) ColumnCheckSql(tableName, colName string) (string, []interface{}) {
|
||||||
args := []interface{}{strings.ToUpper(tableName), strings.ToUpper(colName)}
|
args := []interface{}{strings.ToUpper(tableName), strings.ToUpper(colName)}
|
||||||
return "SELECT column_name FROM USER_TAB_COLUMNS WHERE table_name = ?" +
|
return "SELECT column_name FROM USER_TAB_COLUMNS WHERE table_name = ?" +
|
||||||
" AND column_name = ?", args
|
" AND column_name = ?", args
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) GetColumns(tableName string) ([]string, map[string]*Column, error) {
|
func (db *oracle) GetColumns(tableName string) ([]string, map[string]*Column, error) {
|
||||||
args := []interface{}{strings.ToUpper(tableName)}
|
args := []interface{}{strings.ToUpper(tableName)}
|
||||||
s := "SELECT column_name,data_default,data_type,data_length,data_precision,data_scale," +
|
s := "SELECT column_name,data_default,data_type,data_length,data_precision,data_scale," +
|
||||||
"nullable FROM USER_TAB_COLUMNS WHERE table_name = :1"
|
"nullable FROM USER_TAB_COLUMNS WHERE table_name = :1"
|
||||||
|
|
||||||
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
}
|
}
|
||||||
defer cnn.Close()
|
defer cnn.Close()
|
||||||
res, err := query(cnn, s, args...)
|
res, err := query(cnn, s, args...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
}
|
}
|
||||||
cols := make(map[string]*Column)
|
cols := make(map[string]*Column)
|
||||||
colSeq := make([]string, 0)
|
colSeq := make([]string, 0)
|
||||||
for _, record := range res {
|
for _, record := range res {
|
||||||
col := new(Column)
|
col := new(Column)
|
||||||
col.Indexes = make(map[string]bool)
|
col.Indexes = make(map[string]bool)
|
||||||
for name, content := range record {
|
for name, content := range record {
|
||||||
switch name {
|
switch name {
|
||||||
case "column_name":
|
case "column_name":
|
||||||
col.Name = strings.Trim(string(content), `" `)
|
col.Name = strings.Trim(string(content), `" `)
|
||||||
case "data_default":
|
case "data_default":
|
||||||
col.Default = string(content)
|
col.Default = string(content)
|
||||||
case "nullable":
|
case "nullable":
|
||||||
if string(content) == "Y" {
|
if string(content) == "Y" {
|
||||||
col.Nullable = true
|
col.Nullable = true
|
||||||
} else {
|
} else {
|
||||||
col.Nullable = false
|
col.Nullable = false
|
||||||
}
|
}
|
||||||
case "data_type":
|
case "data_type":
|
||||||
ct := string(content)
|
ct := string(content)
|
||||||
switch ct {
|
switch ct {
|
||||||
case "VARCHAR2":
|
case "VARCHAR2":
|
||||||
col.SQLType = SQLType{Varchar, 0, 0}
|
col.SQLType = SQLType{Varchar, 0, 0}
|
||||||
case "TIMESTAMP WITH TIME ZONE":
|
case "TIMESTAMP WITH TIME ZONE":
|
||||||
col.SQLType = SQLType{TimeStamp, 0, 0}
|
col.SQLType = SQLType{TimeStamp, 0, 0}
|
||||||
default:
|
default:
|
||||||
col.SQLType = SQLType{strings.ToUpper(ct), 0, 0}
|
col.SQLType = SQLType{strings.ToUpper(ct), 0, 0}
|
||||||
}
|
}
|
||||||
if _, ok := sqlTypes[col.SQLType.Name]; !ok {
|
if _, ok := sqlTypes[col.SQLType.Name]; !ok {
|
||||||
return nil, nil, errors.New(fmt.Sprintf("unkonw colType %v", ct))
|
return nil, nil, errors.New(fmt.Sprintf("unkonw colType %v", ct))
|
||||||
}
|
}
|
||||||
case "data_length":
|
case "data_length":
|
||||||
i, err := strconv.Atoi(string(content))
|
i, err := strconv.Atoi(string(content))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, nil, errors.New("retrieve length error")
|
return nil, nil, errors.New("retrieve length error")
|
||||||
}
|
}
|
||||||
col.Length = i
|
col.Length = i
|
||||||
case "data_precision":
|
case "data_precision":
|
||||||
case "data_scale":
|
case "data_scale":
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if col.SQLType.IsText() {
|
if col.SQLType.IsText() {
|
||||||
if col.Default != "" {
|
if col.Default != "" {
|
||||||
col.Default = "'" + col.Default + "'"
|
col.Default = "'" + col.Default + "'"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
cols[col.Name] = col
|
cols[col.Name] = col
|
||||||
colSeq = append(colSeq, col.Name)
|
colSeq = append(colSeq, col.Name)
|
||||||
}
|
}
|
||||||
|
|
||||||
return colSeq, cols, nil
|
return colSeq, cols, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) GetTables() ([]*Table, error) {
|
func (db *oracle) GetTables() ([]*Table, error) {
|
||||||
args := []interface{}{}
|
args := []interface{}{}
|
||||||
s := "SELECT table_name FROM user_tables"
|
s := "SELECT table_name FROM user_tables"
|
||||||
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer cnn.Close()
|
defer cnn.Close()
|
||||||
res, err := query(cnn, s, args...)
|
res, err := query(cnn, s, args...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
tables := make([]*Table, 0)
|
tables := make([]*Table, 0)
|
||||||
for _, record := range res {
|
for _, record := range res {
|
||||||
table := new(Table)
|
table := new(Table)
|
||||||
for name, content := range record {
|
for name, content := range record {
|
||||||
switch name {
|
switch name {
|
||||||
case "table_name":
|
case "table_name":
|
||||||
table.Name = string(content)
|
table.Name = string(content)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
tables = append(tables, table)
|
tables = append(tables, table)
|
||||||
}
|
}
|
||||||
return tables, nil
|
return tables, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *oracle) GetIndexes(tableName string) (map[string]*Index, error) {
|
func (db *oracle) GetIndexes(tableName string) (map[string]*Index, error) {
|
||||||
args := []interface{}{tableName}
|
args := []interface{}{tableName}
|
||||||
s := "SELECT t.column_name,i.table_name,i.uniqueness,i.index_name FROM user_ind_columns t,user_indexes i " +
|
s := "SELECT t.column_name,i.table_name,i.uniqueness,i.index_name FROM user_ind_columns t,user_indexes i " +
|
||||||
"WHERE t.index_name = i.index_name and t.table_name = i.table_name and t.table_name =:1"
|
"WHERE t.index_name = i.index_name and t.table_name = i.table_name and t.table_name =:1"
|
||||||
|
|
||||||
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
cnn, err := sql.Open(db.driverName, db.dataSourceName)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer cnn.Close()
|
defer cnn.Close()
|
||||||
res, err := query(cnn, s, args...)
|
res, err := query(cnn, s, args...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
indexes := make(map[string]*Index, 0)
|
indexes := make(map[string]*Index, 0)
|
||||||
for _, record := range res {
|
for _, record := range res {
|
||||||
var indexType int
|
var indexType int
|
||||||
var indexName string
|
var indexName string
|
||||||
var colName string
|
var colName string
|
||||||
|
|
||||||
for name, content := range record {
|
for name, content := range record {
|
||||||
switch name {
|
switch name {
|
||||||
case "index_name":
|
case "index_name":
|
||||||
indexName = strings.Trim(string(content), `" `)
|
indexName = strings.Trim(string(content), `" `)
|
||||||
case "uniqueness":
|
case "uniqueness":
|
||||||
c := string(content)
|
c := string(content)
|
||||||
if c == "UNIQUE" {
|
if c == "UNIQUE" {
|
||||||
indexType = UniqueType
|
indexType = UniqueType
|
||||||
} else {
|
} else {
|
||||||
indexType = IndexType
|
indexType = IndexType
|
||||||
}
|
}
|
||||||
case "column_name":
|
case "column_name":
|
||||||
colName = string(content)
|
colName = string(content)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
var index *Index
|
var index *Index
|
||||||
var ok bool
|
var ok bool
|
||||||
if index, ok = indexes[indexName]; !ok {
|
if index, ok = indexes[indexName]; !ok {
|
||||||
index = new(Index)
|
index = new(Index)
|
||||||
index.Type = indexType
|
index.Type = indexType
|
||||||
index.Name = indexName
|
index.Name = indexName
|
||||||
indexes[indexName] = index
|
indexes[indexName] = index
|
||||||
}
|
}
|
||||||
index.AddColumn(colName)
|
index.AddColumn(colName)
|
||||||
}
|
}
|
||||||
return indexes, nil
|
return indexes, nil
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue