decodeSQLQuery: function()

in lib/protocol/decoder.js [622:647]

• 26 lines of code
• 6 McCabe index (conditional complexity)

    decodeSQLQuery: function (buffers) {
        const response = tsProtos.SQLQueryResponse.decode(buffers);
        const result = {};
        if (response.consumes) {
            result.consumes = response.consumes;
        }
        if (response.version) {
            result.version = response.version;
        }
        if (response.rows) {
            switch (response.version) {
                case tsProtos.SQLPayloadVersion.SQL_FLAT_BUFFERS: {
                    let buf = new flatbuffers.ByteBuffer(response.rows);
                    let sqlResponseColumns = fbsSQLResponseColumns.getRootAsSQLResponseColumns(buf);
                    result.sqlRows = new TableStore.SQLRows(sqlResponseColumns);
                    break;
                }
                default:
                    throw new Error("not exist SQLPayloadVersion: " + response.version);
            }
        }
        if (response.type) {
            result.type = response.type;
        }
        return result;
    },