BLUE

Navigation

Breadcrumbs

/ / var / www / receipt-app-backend-bitkit.dk / httpdocs / node_modules / mysql2 / lib / packets

Create

Upload

Tip: You can also drag & drop files anywhere on this page to upload.

Edit File Size: 5.03 KB

/var/www/receipt-app-backend-bitkit.dk/httpdocs/node_modules/mysql2/lib/packets/execute.js

Text Base64

'use strict';

const CursorType = require('../constants/cursor');
const CommandCodes = require('../constants/commands');
const ClientConstants = require('../constants/client');
const Types = require('../constants/types');
const Packet = require('../packets/packet');
const CharsetToEncoding = require('../constants/charset_encodings.js');
const { toParameter } = require('./encode_parameter.js');

class Execute {
  constructor(
    id,
    parameters,
    charsetNumber,
    timezone,
    attributes,
    clientFlags
  ) {
    this.id = id;
    this.parameters = parameters;
    this.encoding = CharsetToEncoding[charsetNumber];
    this.timezone = timezone;
    this.attributes = attributes;
    this.clientFlags = clientFlags || 0;
  }

static fromPacket(packet, encoding) {
    const stmtId = packet.readInt32();
    const flags = packet.readInt8();
    const iterationCount = packet.readInt32();

const types = [];

for (let i = packet.offset + 1; i < packet.end - 1; i++) {
      if (
        (packet.buffer[i] === Types.VAR_STRING ||
          packet.buffer[i] === Types.NULL ||
          packet.buffer[i] === Types.DOUBLE ||
          packet.buffer[i] === Types.TINY ||
          packet.buffer[i] === Types.DATETIME ||
          packet.buffer[i] === Types.JSON) &&
        packet.buffer[i + 1] === 0
      ) {
        types.push(packet.buffer[i]);
        packet.skip(2);
      }
    }

packet.skip(1);

return { stmtId, flags, iterationCount, values };
  }

_serializeToBuffer(buffer) {
    const useQueryAttributes =
      this.clientFlags & ClientConstants.CLIENT_QUERY_ATTRIBUTES;

const attrNames =
      useQueryAttributes && this.attributes ? Object.keys(this.attributes) : [];
    const numParams = this.parameters ? this.parameters.length : 0;
    const numAttrs = attrNames.length;
    const totalParams = numParams + numAttrs;

const packet = new Packet(0, buffer, 0, buffer.length);
    packet.offset = 4;
    packet.writeInt8(CommandCodes.STMT_EXECUTE);
    packet.writeInt32(this.id);

let cursorFlags = CursorType.NO_CURSOR;
    if (useQueryAttributes) {
      cursorFlags |= CursorType.PARAMETER_COUNT_AVAILABLE;
    }
    packet.writeInt8(cursorFlags);
    packet.writeInt32(1); // iteration-count, always 1

if (useQueryAttributes) {
      packet.writeLengthCodedNumber(totalParams);
    }

if (totalParams > 0) {
      const bindParams =
        numParams > 0
          ? this.parameters.map((v) =>
              toParameter(v, this.encoding, this.timezone)
            )
          : [];
      const attrParams = attrNames.map((name) =>
        toParameter(this.attributes[name], this.encoding, this.timezone)
      );
      const allParams = bindParams.concat(attrParams);

// null bitmap
      let bitmap = 0;
      let bitValue = 1;
      allParams.forEach((parameter) => {
        if (parameter.type === Types.NULL) {
          bitmap += bitValue;
        }
        bitValue *= 2;
        if (bitValue === 256) {
          packet.writeInt8(bitmap);
          bitmap = 0;
          bitValue = 1;
        }
      });
      if (bitValue !== 1) {
        packet.writeInt8(bitmap);
      }

packet.writeInt8(1); // new-params-bound-flag

// types (and names for attributes)
      for (let i = 0; i < allParams.length; i++) {
        packet.writeInt8(allParams[i].type);
        packet.writeInt8(0); // unsigned flag
        if (useQueryAttributes) {
          const name = i < numParams ? '' : attrNames[i - numParams];
          packet.writeLengthCodedString(name, this.encoding);
        }
      }

// values
      allParams.forEach((parameter) => {
        if (parameter.type !== Types.NULL) {
          parameter.writer.call(packet, parameter.value);
        }
      });
    }

return packet;
  }

toPacket() {
    const p = this._serializeToBuffer(Packet.MockBuffer());
    return this._serializeToBuffer(Buffer.allocUnsafe(p.offset));
  }
}

module.exports = Execute;

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 0 × Files: 24

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
auth_next_factor.js	918 B	lrw-r--r--	2026-05-06 08:23:45	Edit Download recursive recursive
auth_switch_request.js	1.03 KB	lrw-r--r--	2026-05-06 08:23:45	Edit Download recursive recursive
auth_switch_request_more_data.js	793 B	lrw-r--r--	2026-05-06 08:23:45	Edit Download recursive recursive
auth_switch_response.js	707 B	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
binary_row.js	3.20 KB	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
binlog_dump.js	984 B	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
binlog_query_statusvars.js	3.43 KB	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
change_user.js	3.23 KB	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
close_statement.js	454 B	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
column_definition.js	9.70 KB	lrw-r--r--	2026-05-06 08:23:46	Edit Download recursive recursive
encode_parameter.js	1.87 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
execute.js	5.03 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
handshake.js	3.83 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
handshake_response.js	6.07 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
index.js	4.61 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
packet.js	26.23 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
prepared_statement_header.js	375 B	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
prepare_statement.js	800 B	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
query.js	3.06 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
register_slave.js	1.59 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
reset_connection.js	368 B	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
resultset_header.js	4.81 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
ssl_request.js	633 B	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive
text_row.js	1.17 KB	lrw-r--r--	2026-05-06 08:23:47	Edit Download recursive recursive