Вставить данные в гаечный ключ с параметрами - PullRequest
Новая
       3

Вставить данные в гаечный ключ с параметрами

0 голосов
/ 01 ноября 2018

Я хочу передать переменные в мой оператор вставки SQL. Кажется, Spanner использует следующий синтаксис для указания переменной @param. Как описано в https://cloud.google.com/spanner/docs/lexical#query-parameters. Я новичок в Python, поэтому я не думаю, что я полностью понимаю синтаксис, потому что он выдает ошибку «Не найден параметр для привязки: messageid» Тот же код выполняется правильно с жестко закодированными значениями.

Вот мой код: 

messageid = str(uuid.uuid4())
sender = newmsg['Sender']
recipient = newmsg['Recipient']
message = newmsg['Message']

def insert_message(transaction):
    self.logger.debug("Inside insert_with_dml")
    row_ct = transaction.execute_update(
        "INSERT MESSAGE_STORE (MessageId, Message, MessageRecipient, MessageSender) "
        " VALUES (@messageid, @message, @recipient, @sender)"
    )

Обновление: вот рабочий код, если кому-то интересно 

def insertmessage(self, newmsg):
            messageid = str(uuid.uuid4())
            sender = newmsg['Sender']
            recipient = newmsg['Recipient']
            message = newmsg['Message']

            data_type = param_types.Struct([
                    param_types.StructField('Id', param_types.STRING),
                    param_types.StructField('Msg', param_types.STRING),
                    param_types.StructField('Requestor', param_types.STRING),
                    param_types.StructField('MsgRecipient', param_types.STRING)
            ])

            data_values = (messageid, message, recipient, sender)

            def insert_message(transaction):
                self.logger.debug("Inside insert_with_dml")
                row_ct = transaction.execute_update(
                    "INSERT MESSAGE_STORE (MessageId, Message, MessageRecipient, MessageSender) "
                        "VALUES (@values.Id, @values.Msg, @values.Requestor, @values.MsgRecipient)",
                        params={'values' : data_values},
                        param_types={'values' : data_type}
            )

                self.logger.debug("{} record(s) inserted.".format(row_ct))

            try:
                self.client.run_in_transaction(insert_message)
            except Exception as e:
                self.logger.debug(e)

            self.logger.debug("Before Output")
            output = "{ 'Message Id':" +  messageid +", 'Result Code': '1' }"
            return output

1 Ответ

0 голосов
/ 01 ноября 2018
...