mssql

package module

Go to main page

Versions in this module

v1

v1.7.1

Mar 19, 2024

v1.7.0

Feb 21, 2024

Changes in this version

+ type NullUniqueIdentifier struct

+ UUID UniqueIdentifier

+ Valid bool

+ func (n *NullUniqueIdentifier) Scan(v interface{}) error

+ func (n *NullUniqueIdentifier) UnmarshalJSON(b []byte) error

+ func (n NullUniqueIdentifier) MarshalText() (text []byte, err error)

+ func (n NullUniqueIdentifier) String() string

+ func (n NullUniqueIdentifier) Value() (driver.Value, error)

v1.6.0

Aug 31, 2023

Changes in this version

+ const AzureKeyVaultKeyProvider

+ const CertificateStoreKeyProvider

+ const CngKeyProvider

+ const CspKeyProvider

+ const JavaKeyProvider

+ const KeyEncryptionAlgorithm

+ type ColumnEncryptionType int

+ var ColumnEncryptionDeterministic ColumnEncryptionType = 1

+ var ColumnEncryptionPlainText ColumnEncryptionType = 0

+ var ColumnEncryptionRandomized ColumnEncryptionType = 2

type Connector

+ func (c *Connector) RegisterCekProvider(name string, provider aecmk.ColumnEncryptionKeyProvider)

+ type NChar string

+ type RWCBuffer struct

+ func (R RWCBuffer) Close() error

+ func (R RWCBuffer) Read(p []byte) (n int, err error)

+ func (R RWCBuffer) Write(p []byte) (n int, err error)

+ type TSQLQuoter struct

+ func (TSQLQuoter) ID(name string) string

+ func (TSQLQuoter) Value(v interface{}) string

v1.5.0

Jul 25, 2023

v1.4.0

Jul 20, 2023

Changes in this version

+ type HostDialer interface

+ HostName func() string

type UniqueIdentifier

+ func (u *UniqueIdentifier) UnmarshalJSON(b []byte) error

v1.3.0

Jun 16, 2023

v1.2.0

May 30, 2023

v1.1.0

May 30, 2023

v1.0.0

May 25, 2023

v0

v0.21.0

Mar 28, 2023

v0.20.0

Jan 20, 2023

v0.19.0

Dec 21, 2022

v0.18.0

Dec 5, 2022

Changes in this version

+ const FedAuthADALWorkflowNone

+ type MssqlProtocolDialer interface

+ DialSqlConnection func(ctx context.Context, c *Connector, p msdsn.Config) (conn net.Conn, err error)

v0.17.0

Aug 17, 2022

v0.16.0

Aug 8, 2022

v0.15.0

Jun 21, 2022

Changes in this version

type Connector

+ func NewConnectorWithAccessTokenProvider(dsn string, tokenProvider func(ctx context.Context) (string, error)) (*Connector, error)

v0.14.0

May 19, 2022

Changes in this version

type Error

+ func (e Error) String() string

v0.13.2

Apr 29, 2022

v0.13.0

Apr 25, 2022

Changes in this version

+ const FedAuthADALWorkflowIntegrated

+ const FedAuthADALWorkflowMSI

+ const FedAuthADALWorkflowPassword

+ const FedAuthLibraryADAL

+ const FedAuthLibraryLiveIDCompactToken

+ const FedAuthLibraryReserved

+ const FedAuthLibrarySecurityToken

+ const ISC_REQ — windows/amd64

+ const ISC_REQ_CONFIDENTIALITY — windows/amd64

+ const ISC_REQ_CONNECTION — windows/amd64

+ const ISC_REQ_DELEGATE — windows/amd64

+ const ISC_REQ_REPLAY_DETECT — windows/amd64

+ const ISC_REQ_SEQUENCE_DETECT — windows/amd64

+ const NTLMBUF_LEN — windows/amd64

+ const SECBUFFER_TOKEN — windows/amd64

+ const SECBUFFER_VERSION — windows/amd64

+ const SECPKG_CRED_OUTBOUND — windows/amd64

+ const SECURITY_NETWORK_DREP — windows/amd64

+ const SEC_E_OK — windows/amd64

+ const SEC_I_COMPLETE_AND_CONTINUE — windows/amd64

+ const SEC_I_COMPLETE_NEEDED — windows/amd64

+ const SEC_I_CONTINUE_NEEDED — windows/amd64

+ const SEC_WINNT_AUTH_IDENTITY_UNICODE — windows/amd64

+ var ErrorEmptyTVPTypeName = errors.New("TypeName must not be empty")

+ var ErrorObjectName = errors.New("wrong tvp name")

+ var ErrorSkip = errors.New("all fields mustn't skip")

+ var ErrorTypeSlice = errors.New("TVP must be slice type")

+ var ErrorTypeSliceIsEmpty = errors.New("TVP mustn't be null value")

+ var ErrorWrongTyping = errors.New("the number of elements in columnStr and tvpFieldIndexes do not align")

+ func CopyIn(table string, options BulkOptions, columns ...string) string

+ func IsSkipField(tvpTagValue string, isTvpValue bool, jsonTagValue string, isJsonTagValue bool) bool

+ func NewAccessTokenConnector(dsn string, tokenProvider func() (string, error)) (driver.Connector, error)

+ func SetContextLogger(ctxLogger ContextLogger)

+ func SetLogger(logger Logger)

+ type Bulk struct

+ Debug bool

+ Options BulkOptions

+ func (b *Bulk) AddRow(row []interface{}) (err error)

+ func (b *Bulk) Done() (rowcount int64, err error)

+ type BulkOptions struct

+ CheckConstraints bool

+ FireTriggers bool

+ KeepNulls bool

+ KilobytesPerBatch int

+ Order []string

+ RowsPerBatch int

+ Tablock bool

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *Conn) CheckNamedValue(nv *driver.NamedValue) error

+ func (c *Conn) Close() error

+ func (c *Conn) Commit() error

+ func (c *Conn) IsValid() bool

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) ResetSession(ctx context.Context) error

+ func (c *Conn) Rollback() error

+ func (cn *Conn) CreateBulk(table string, columns []string) (_ *Bulk)

+ func (cn *Conn) CreateBulkContext(ctx context.Context, table string, columns []string) (_ *Bulk)

+ type Connector struct

+ Dialer Dialer

+ SessionInitSQL string

+ func NewActiveDirectoryTokenConnector(config msdsn.Config, adalWorkflow byte, ...) (*Connector, error)

+ func NewConnector(dsn string) (*Connector, error)

+ func NewConnectorConfig(config msdsn.Config) *Connector

+ func NewSecurityTokenConnector(config msdsn.Config, tokenProvider func(ctx context.Context) (string, error)) (*Connector, error)

+ func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (c *Connector) Driver() driver.Driver

+ type ContextLogger interface

+ Log func(ctx context.Context, category msdsn.Log, msg string)

+ type DataValue interface

+ type DateTime1 time.Time

+ type DateTimeOffset time.Time

+ type Dialer interface

+ DialContext func(ctx context.Context, network string, addr string) (net.Conn, error)

+ type Driver struct

+ func (d *Driver) Open(dsn string) (driver.Conn, error)

+ func (d *Driver) OpenConnection(dsn string) (*Conn, error)

+ func (d *Driver) OpenConnector(dsn string) (*Connector, error)

+ func (d *Driver) SetContextLogger(ctxLogger ContextLogger)

+ func (d *Driver) SetLogger(logger Logger)

+ type Error struct

+ All []Error

+ Class uint8

+ LineNo int32

+ Message string

+ Number int32

+ ProcName string

+ ServerName string

+ State uint8

+ func (e Error) Error() string

+ func (e Error) SQLErrorClass() uint8

+ func (e Error) SQLErrorLineNo() int32

+ func (e Error) SQLErrorMessage() string

+ func (e Error) SQLErrorNumber() int32

+ func (e Error) SQLErrorProcName() string

+ func (e Error) SQLErrorServerName() string

+ func (e Error) SQLErrorState() uint8

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ type MssqlBulk = Bulk

+ type MssqlBulkOptions = BulkOptions

+ type MssqlConn = Conn

+ type MssqlDriver = Driver

+ type MssqlResult = Result

+ type MssqlRows = Rows

+ type MssqlStmt = Stmt

+ type NVarCharMax string

+ type Result struct

+ func (r *Result) LastInsertId() (int64, error)

+ func (r *Result) RowsAffected() (int64, error)

+ type RetryableError struct

+ func (r RetryableError) Error() string

+ func (r RetryableError) Is(err error) bool

+ func (r RetryableError) Unwrap() error

+ type ReturnStatus int32

+ type Rows struct

+ func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rows) ColumnTypeLength(index int) (int64, bool)

+ func (r *Rows) ColumnTypeNullable(index int) (nullable, ok bool)

+ func (r *Rows) ColumnTypePrecisionScale(index int) (int64, int64, bool)

+ func (r *Rows) ColumnTypeScanType(index int) reflect.Type

+ func (rc *Rows) Close() error

+ func (rc *Rows) Columns() (res []string)

+ func (rc *Rows) HasNextResultSet() bool

+ func (rc *Rows) Next(dest []driver.Value) error

+ func (rc *Rows) NextResultSet() error

+ type Rowsq struct

+ func (r *Rowsq) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rowsq) ColumnTypeLength(index int) (int64, bool)

+ func (r *Rowsq) ColumnTypeNullable(index int) (nullable, ok bool)

+ func (r *Rowsq) ColumnTypePrecisionScale(index int) (int64, int64, bool)

+ func (r *Rowsq) ColumnTypeScanType(index int) reflect.Type

+ func (rc *Rowsq) Close() error

+ func (rc *Rowsq) Columns() (res []string)

+ func (rc *Rowsq) HasNextResultSet() bool

+ func (rc *Rowsq) Next(dest []driver.Value) error

+ func (rc *Rowsq) NextResultSet() error

+ type SEC_WINNT_AUTH_IDENTITY struct — windows/amd64

+ Domain *uint16

+ DomainLength uint32

+ Flags uint32

+ Password *uint16

+ PasswordLength uint32

+ User *uint16

+ UserLength uint32

+ type SSPIAuth struct — windows/amd64

+ Domain string

+ Password string

+ Service string

+ UserName string

+ func (auth *SSPIAuth) Free()

+ func (auth *SSPIAuth) InitialBytes() ([]byte, error)

+ func (auth *SSPIAuth) NextBytes(bytes []byte) ([]byte, error)

+ type SecBuffer struct — windows/amd64

+ BufferType uint32

+ type SecBufferDesc struct — windows/amd64

+ type SecHandle struct — windows/amd64

+ type SecurityFunctionTable struct — windows/amd64

+ AcceptSecurityContext uintptr

+ AcquireCredentialsHandle uintptr

+ ApplyControlToken uintptr

+ CompleteAuthToken uintptr

+ DecryptMessage uintptr

+ DeleteSecurityContext uintptr

+ EncryptMessage uintptr

+ EnumerateSecurityPackages uintptr

+ FreeContextBuffer uintptr

+ FreeCredentialsHandle uintptr

+ ImpersonateSecurityContext uintptr

+ InitializeSecurityContext uintptr

+ MakeSignature uintptr

+ QueryContextAttributes uintptr

+ QueryCredentialsAttributes uintptr

+ QuerySecurityContextToken uintptr

+ QuerySecurityPackageInfo uintptr

+ Reserved2 uintptr

+ Reserved3 uintptr

+ Reserved4 uintptr

+ Reserved5 uintptr

+ Reserved6 uintptr

+ Reserved7 uintptr

+ Reserved8 uintptr

+ RevertSecurityContext uintptr

+ VerifySignature uintptr

+ type ServerError struct

+ func (e ServerError) Error() string

+ func (e ServerError) Unwrap() error

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ func (s *Stmt) SetQueryNotification(id, options string, timeout time.Duration)

+ type StreamError struct

+ InnerError error

+ func (e StreamError) Error() string

+ type TVP struct

+ TypeName string

+ Value interface{}

+ type TimeStamp struct — windows/amd64

+ HighPart int32

+ LowPart uint32

+ type UniqueIdentifier [16]byte

+ func (u *UniqueIdentifier) Scan(v interface{}) error

+ func (u UniqueIdentifier) MarshalText() []byte

+ func (u UniqueIdentifier) String() string

+ func (u UniqueIdentifier) Value() (driver.Value, error)

+ type VarChar string

+ type VarCharMax string

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