dbms

package

v1.0.0 Latest Latest Go to latest Published: Dec 16, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kpo12/go-ora

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DisableOutput(ctx context.Context) error
func EnableOutput(ctx context.Context, conn *sql.DB) error
func GetOutput(ctx context.Context) (string, error)
func PrintOutput(ctx context.Context, w io.StringWriter) error
type AQ
- func NewAQ(conn *sql.DB, name, typeName string) *AQ
type DBOutput
- func NewOutput(conn *sql.DB, bufferSize int) (*DBOutput, error)

Constants ¶

View Source

const (
	MaxBufferSize = 0x7FFF
	MinBufferSize = 2000
	KeyInContext  = "GO-ORA.DBMS_OUTPUT"
)

Variables ¶

This section is empty.

Functions ¶

func DisableOutput ¶

func DisableOutput(ctx context.Context) error

disable oracle output for current session

func EnableOutput ¶

func EnableOutput(ctx context.Context, conn *sql.DB) error

enable oracle output for current session param:

ctx: context of goroutine used in large apps
     for main: context.Background()
     for rest apis:
       http.Request.Context()
       gin.Context
       fiber.Ctx.Context()
       ...

func GetOutput ¶

func GetOutput(ctx context.Context) (string, error)

get oracle output for current session

func PrintOutput ¶

func PrintOutput(ctx context.Context, w io.StringWriter) error

print oracle output into StringWriter for current session

Types ¶

type AQ ¶

type AQ struct {
	Name          string `db:"QUEUE_NAME"`
	TableName     string `db:"TB_NAME"`
	TypeName      string `db:"TYPE_NAME"`
	Owner         string
	MaxRetry      int64  `db:"MAX_RETRY"`
	RetryDelay    int64  `db:"RETRY_DELAY"`
	RetentionTime int64  `db:"RETENTION_TIME"`
	Comment       string `db:"COMMENT"`
	// contains filtered or unexported fields
}

func NewAQ ¶

func NewAQ(conn *sql.DB, name, typeName string) *AQ

func (*AQ) Create ¶

func (aq *AQ) Create() error

func (*AQ) Dequeue ¶

func (aq *AQ) Dequeue(message driver.Value, messageSize int) (messageID []byte, err error)

func (*AQ) Drop ¶

func (aq *AQ) Drop() error

func (*AQ) Enqueue ¶

func (aq *AQ) Enqueue(message driver.Value) (messageID []byte, err error)

func (*AQ) Start ¶

func (aq *AQ) Start(enqueue, dequeue bool) error

enable both enqueue and dequeue

func (*AQ) Stop ¶

func (aq *AQ) Stop(enqueue, dequeue bool) error

disable both enqueue and dequeue

type DBOutput ¶

type DBOutput struct {
	// contains filtered or unexported fields
}

func NewOutput ¶

func NewOutput(conn *sql.DB, bufferSize int) (*DBOutput, error)

func (*DBOutput) Close ¶

func (output *DBOutput) Close() error

func (*DBOutput) GetOutput ¶

func (db_out *DBOutput) GetOutput() (string, error)

func (*DBOutput) Print ¶

func (db_out *DBOutput) Print(w io.StringWriter) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL