Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EfsDataBaseConfigStruct ¶
type EfsDataBaseConfigStruct struct {
RemoteIP []string `yaml:"RemoteIP"`
RemoteUserByIP []string `yaml:"RemoteUserByIP"`
RemotePasswdByIP []string `yaml:"RemotePasswdByIP"`
RemotePortByIP []string `yaml:"RemotePortByIP"`
RemoteServiceNameByIP []string `yaml:"RemoteServiceNameByIP"`
RemoteUser string `yaml:"RemoteUser"`
RemotePasswd string `yaml:"RemotePasswd"`
RemotePort int `yaml:"RemotePort"`
RemoteServiceName string `yaml:"RemoteServiceName"`
// contains filtered or unexported fields
}
var (
EfsDataBaseConfig EfsDataBaseConfigStruct
)
func (*EfsDataBaseConfigStruct) PreprocessConfig ¶
func (d *EfsDataBaseConfigStruct) PreprocessConfig()
PreprocessConfig 实现ConfigStruct接口
func (*EfsDataBaseConfigStruct) SetDefaultConfig ¶
func (d *EfsDataBaseConfigStruct) SetDefaultConfig()
SetDefaultConfig 实现ConfigStruct接口
func (*EfsDataBaseConfigStruct) ValidateConfig ¶
func (d *EfsDataBaseConfigStruct) ValidateConfig() error
ValidateConfig 实现ConfigStruct接口
type OracleClient ¶
type OracleClient struct {
// contains filtered or unexported fields
}
func NewOracleClient ¶
func NewOracleClient(ip, privateKeyParam string) (*OracleClient, error)
NewOracleClient 根据配置和私钥创建 Oracle 数据库客户端。 参数:
- ip 为目标数据库服务器 IP，
- privateKeyParam 用于解密配置中加密的密码。
返回值：
- *OracleClient: 创建成功的数据库客户端。
- error: 参数校验失败时返回错误信息。
func NewOracleClientFromParams ¶ added in v1.0.6
func NewOracleClientFromParams(ip, user, password string, port int, serviceName string) (*OracleClient, error)
NewOracleClientFromParams 根据给定的连接参数创建 Oracle 数据库客户端。 参数：
- ip: 数据库服务器 IP 地址。
- user: 数据库用户名。
- password: 数据库密码。
- port: 数据库端口（1-65535）。
- serviceName: Oracle 服务名称。
返回值：
- *OracleClient: 创建成功的数据库客户端。
- error: 参数校验失败时返回错误信息。
func (*OracleClient) Close ¶
func (o *OracleClient) Close() error
Close 关闭Oracle数据库连接。 如果连接尚未初始化，则直接返回nil，不执行任何操作。
func (*OracleClient) ExecSQLBatch ¶
func (o *OracleClient) ExecSQLBatch(sqlStrings []string) error
ExecSQLBatch 在单个事务中批量执行多条SQL语句。
执行流程：先检查连接与SQL列表，测试数据库连接可用性，开启事务后逐条执行； 任意一条SQL执行失败即回滚整个事务；全部成功后再统一提交。 注意：该函数会记录SQL文本到日志，调用方需确保SQL中不含敏感信息。
参数：
- sqlStrings: 待执行的SQL语句列表（可带结尾分号，执行前会自动去除）。
返回值：
- error: 数据库未连接、SQL列表为空、连接不可用、SQL执行失败、回滚失败或提交失败时返回错误；全部成功返回nil。
func (*OracleClient) ExecSQLFile ¶
func (o *OracleClient) ExecSQLFile(filePath string) error
ExecSQLFile 读取指定路径的SQL文件并批量执行其中的所有SQL语句。 该函数使用引号/注释感知的方式按分号拆分SQL语句，能够正确处理字符串字面量与PL/SQL块内部分号，避免SQL被错误截断。
参数：
- filePath: 待执行的SQL文件路径。
返回值：
- error: 读取文件失败、文件为空或SQL执行失败时返回对应错误。
func (*OracleClient) Init ¶
func (o *OracleClient) Init() error
Init 建立 Oracle 数据库连接并配置连接池参数。 连接成功后验证数据库连通性，并将连接对象保存到 OracleClient 中。 参数：
- 无。
返回值：
- error: 连接建立、池参数配置或连通性验证失败时返回错误。
Source Files
Click to show internal directories.
Click to hide internal directories.