123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401 |
- package xugu
- import (
- "bufio"
- "encoding/binary"
- "errors"
- "fmt"
- "net"
- )
- type SrvResponse struct {
- FormArgDescri []*FormArgDescri
- SelectResult []*SelectResult
- InsertResult []*InsertResult
- UpdateResult []*UpdateResult
- DeleteResult []*DeleteResult
- ProcRet []*ProcRet
- OutParamRet []*OutParamRet
- ErrInfo []*ErrInfo
- WarnInfo []*WarnInfo
- Message []*Message
- }
- func readString(reader *bufio.Reader, length int) (string, error) {
- bytes := make([]byte, length)
- _, err := reader.Read(bytes)
- return string(bytes), err
- }
- func parseFieldDescri(reader *bufio.Reader) (FieldDescri, error) {
- fieldDescri := FieldDescri{}
- var err error
- fieldDescri.FieldNameLen, err = readInt32(reader)
- if err != nil {
- return fieldDescri, err
- }
- fieldDescri.FieldName, err = readString(reader, fieldDescri.FieldNameLen)
- if err != nil {
- return fieldDescri, err
- }
-
-
-
-
- fieldDescri.FieldPreciScale, err = readInt32(reader)
- if err != nil {
- return fieldDescri, err
- }
- fieldDescri.FieldFlag, err = readInt32(reader)
- if err != nil {
- return fieldDescri, err
- }
- return fieldDescri, nil
- }
- func xgSockRecvCommand(pConn *xuguConn) {
- }
- func xgSockRecvData(conn net.Conn, buffer *[]byte) (int, error) {
-
- n, err := conn.Read(*buffer)
- if err != nil {
- fmt.Println("接收服务器消息错误Error reading from server:", err)
- return 0, err
- }
- return n, nil
- }
- func rhRecv(pConn *xuguConn, buff []byte, dLen uint32) error {
-
- if pConn.bkChar != 0x0 {
- buff[0] = pConn.bkChar
- pConn.bkChar = 0x0
-
- dLen--
- }
-
- if dLen != 0 {
- for dLen != 0 {
- if pConn.useSSL {
- buffer := make([]byte, 1024)
- n, err := pConn.conn.Read(buffer)
- if err != nil {
- return err
- } else {
-
- }
- if n <= 0 {
- return errors.New("read error")
- }
- }
- }
-
- }
- return nil
- }
- func rhRecvChar(pConn *xuguConn, valp *byte) (bool, error) {
- var ch [1]byte
- err := rhRecv(pConn, ch[:], 1)
- if err != nil {
- return false, err
- }
- fmt.Println("ch[] = ", ch[:])
- *valp = ch[0]
- return true, nil
- }
- func rhRecvStr(pConn *xuguConn, valp *[]byte) (int, error) {
- var len uint32
- if err := rhRecvInt32(pConn, &len); err != nil {
- return -4, err
- }
- pBuff := make([]byte, len+1)
- if err := rhRecv(pConn, pBuff, len); err != nil {
- return -4, err
- }
- pBuff[len] = 0x0
- *valp = pBuff
- return 0, nil
- }
- func rhRecvInt32(pconn *xuguConn, i *uint32) error {
- var buff [4]byte
- err := rhRecv(pconn, buff[:], 4)
- if err != nil {
- return err
- }
-
- *i = binary.BigEndian.Uint32(buff[:])
- return nil
- }
- func readInt32(reader *bufio.Reader) (int, error) {
- var value int32
- err := binary.Read(reader, binary.BigEndian, &value)
- return int(value), err
- }
- func recvRecord() {
- }
|