Source code for q2_sdk.hq.db.gt_data

from q2_sdk.core.dynamic_imports import (
    api_ExecuteStoredProcedure as ExecuteStoredProcedure,
)
from .db_object import DbObject




class GtData(DbObject):


    async def create(self, data_element_name, transaction_id, value):
        response = await self.call_hq(
            "Q2_AddUpdateGTData",
            ExecuteStoredProcedure.SqlParameters([
                ExecuteStoredProcedure.SqlParam(
                    ExecuteStoredProcedure.DataType.VarChar,
                    "dataElement",
                    data_element_name,
                ),
                ExecuteStoredProcedure.SqlParam(
                    ExecuteStoredProcedure.DataType.Int, "GTID", transaction_id
                ),
                ExecuteStoredProcedure.SqlParam(
                    ExecuteStoredProcedure.DataType.VarChar, "data", value
                ),
            ]),
        )

        return response