| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247 |
- package gocql
- import (
- "errors"
- "net"
- )
- const (
- protoRequest byte = 0x02
- protoResponse byte = 0x82
- opError byte = 0x00
- opStartup byte = 0x01
- opReady byte = 0x02
- opAuthenticate byte = 0x03
- opOptions byte = 0x05
- opSupported byte = 0x06
- opQuery byte = 0x07
- opResult byte = 0x08
- opPrepare byte = 0x09
- opExecute byte = 0x0A
- opRegister byte = 0x0B
- opEvent byte = 0x0C
- opBatch byte = 0x0D
- opAuthChallenge byte = 0x0E
- opAuthResponse byte = 0x0F
- opAuthSuccess byte = 0x10
- resultKindVoid = 1
- resultKindRows = 2
- resultKindKeyspace = 3
- resultKindPrepared = 4
- resultKindSchemaChanged = 5
- flagQueryValues uint8 = 1
- headerSize = 8
- )
- var ErrInvalid = errors.New("invalid response")
- type buffer []byte
- func (b *buffer) writeInt(v int32) {
- p := b.grow(4)
- (*b)[p] = byte(v >> 24)
- (*b)[p+1] = byte(v >> 16)
- (*b)[p+2] = byte(v >> 8)
- (*b)[p+3] = byte(v)
- }
- func (b *buffer) writeShort(v uint16) {
- p := b.grow(2)
- (*b)[p] = byte(v >> 8)
- (*b)[p+1] = byte(v)
- }
- func (b *buffer) writeString(v string) {
- b.writeShort(uint16(len(v)))
- p := b.grow(len(v))
- copy((*b)[p:], v)
- }
- func (b *buffer) writeLongString(v string) {
- b.writeInt(int32(len(v)))
- p := b.grow(len(v))
- copy((*b)[p:], v)
- }
- func (b *buffer) writeUUID() {
- }
- func (b *buffer) writeStringList(v []string) {
- b.writeShort(uint16(len(v)))
- for i := range v {
- b.writeString(v[i])
- }
- }
- func (b *buffer) writeByte(v byte) {
- p := b.grow(1)
- (*b)[p] = v
- }
- func (b *buffer) writeBytes(v []byte) {
- if v == nil {
- b.writeInt(-1)
- return
- }
- b.writeInt(int32(len(v)))
- p := b.grow(len(v))
- copy((*b)[p:], v)
- }
- func (b *buffer) writeShortBytes(v []byte) {
- b.writeShort(uint16(len(v)))
- p := b.grow(len(v))
- copy((*b)[p:], v)
- }
- func (b *buffer) writeInet(ip net.IP, port int) {
- p := b.grow(1 + len(ip))
- (*b)[p] = byte(len(ip))
- copy((*b)[p+1:], ip)
- b.writeInt(int32(port))
- }
- func (b *buffer) writeConsistency() {
- }
- func (b *buffer) writeStringMap(v map[string]string) {
- b.writeShort(uint16(len(v)))
- for key, value := range v {
- b.writeString(key)
- b.writeString(value)
- }
- }
- func (b *buffer) writeStringMultimap(v map[string][]string) {
- b.writeShort(uint16(len(v)))
- for key, values := range v {
- b.writeString(key)
- b.writeStringList(values)
- }
- }
- func (b *buffer) setHeader(version, flags, stream, opcode uint8) {
- (*b)[0] = version
- (*b)[1] = flags
- (*b)[2] = stream
- (*b)[3] = opcode
- }
- func (b *buffer) setLength(length int) {
- (*b)[4] = byte(length >> 24)
- (*b)[5] = byte(length >> 16)
- (*b)[6] = byte(length >> 8)
- (*b)[7] = byte(length)
- }
- func (b *buffer) Length() int {
- return int((*b)[4])<<24 | int((*b)[5])<<16 | int((*b)[6])<<8 | int((*b)[7])
- }
- func (b *buffer) grow(n int) int {
- if len(*b)+n >= cap(*b) {
- buf := make(buffer, len(*b), len(*b)*2+n)
- copy(buf, *b)
- *b = buf
- }
- p := len(*b)
- *b = (*b)[:p+n]
- return p
- }
- func (b *buffer) skipHeader() {
- *b = (*b)[headerSize:]
- }
- func (b *buffer) readInt() int {
- if len(*b) < 4 {
- panic(ErrInvalid)
- }
- v := int((*b)[0])<<24 | int((*b)[1])<<16 | int((*b)[2])<<8 | int((*b)[3])
- *b = (*b)[4:]
- return v
- }
- func (b *buffer) readShort() uint16 {
- if len(*b) < 2 {
- panic(ErrInvalid)
- }
- v := uint16((*b)[0])<<8 | uint16((*b)[1])
- *b = (*b)[2:]
- return v
- }
- func (b *buffer) readString() string {
- n := int(b.readShort())
- if len(*b) < n {
- panic(ErrInvalid)
- }
- v := string((*b)[:n])
- *b = (*b)[n:]
- return v
- }
- func (b *buffer) readBytes() []byte {
- n := b.readInt()
- if n < 0 {
- return nil
- }
- if len(*b) < n {
- panic(ErrInvalid)
- }
- v := (*b)[:n]
- *b = (*b)[n:]
- return v
- }
- func (b *buffer) readShortBytes() []byte {
- n := int(b.readShort())
- if len(*b) < n {
- panic(ErrInvalid)
- }
- v := (*b)[:n]
- *b = (*b)[n:]
- return v
- }
- func (b *buffer) readTypeInfo() *TypeInfo {
- x := b.readShort()
- typ := &TypeInfo{Type: Type(x)}
- switch typ.Type {
- case TypeCustom:
- typ.Custom = b.readString()
- case TypeMap:
- typ.Key = b.readTypeInfo()
- fallthrough
- case TypeList, TypeSet:
- typ.Value = b.readTypeInfo()
- }
- return typ
- }
- func (b *buffer) readMetaData() []columnInfo {
- flags := b.readInt()
- numColumns := b.readInt()
- globalKeyspace := ""
- globalTable := ""
- if flags&1 != 0 {
- globalKeyspace = b.readString()
- globalTable = b.readString()
- }
- info := make([]columnInfo, numColumns)
- for i := 0; i < numColumns; i++ {
- info[i].Keyspace = globalKeyspace
- info[i].Table = globalTable
- if flags&1 == 0 {
- info[i].Keyspace = b.readString()
- info[i].Table = b.readString()
- }
- info[i].Name = b.readString()
- info[i].TypeInfo = b.readTypeInfo()
- }
- return info
- }
|