Example: FNC_GetDatasetInputLob - Analytics Database - Teradata Vantage

SQL External Routine Programming

Deployment
VantageCloud
VantageCore
Edition
Enterprise
IntelliFlex
VMware
Product
Analytics Database
Teradata Vantage
Release Number
17.20
Published
June 2022
Language
English (United States)
Last Update
2023-07-11
dita:mapPath
iiv1628111441820.ditamap
dita:ditavalPath
qkf1628213546010.ditaval
dita:id
B035-1147
lifecycle
latest
Product Category
Teradata Vantageā„¢

Example Setup

This example references the following table and data.

CREATE TABLE datasetTable(
	id INTEGER, 
	avroFile DATASET STORAGE FORMAT Avro);

avro01.data:

7B2274797065223A227265636F7264222C226E616D65223A227265635F30222C226669656C6473223A5B7B226E616D65223A2261222C2274797065223A22696E74227D5D7D0002 |1|base16
.import vartext file avro01.data
USING (avroData VARCHAR(1000), id varchar(10), encoding VARCHAR(20))
INSERT INTO datasetTable (cast(:id AS INTEGER),cast(TO_BYTES(:avroData, :encoding) AS DATASET STORAGE FORMAT AVRO));

Example Using FNC_GetDatasetInputLob

REPLACE FUNCTION getLobData ( a1 TD_ANYTYPE)  
RETURNS TD_ANYTYPE
NO SQL
PARAMETER STYLE TD_GENERAL
DETERMINISTIC
LANGUAGE C
EXTERNAL NAME 'CS!getLobData!getLobData.c!F!getLobData';

getLobData.c:

#define SQL_TEXT Latin_Text
#include <sqltypes_td.h>
#include <string.h>
#include <stdio.h>
void getLobData ( DATASET_HANDLE *dataset_instance,
                  void *result,
                  char sqlstate[6])
{
   int max_length = 0;
   int in_line_length = 0; 
   int schema_length = 0;
	  int raw_data_length=0;
	  dataset_storage_et dataset_storage = DATASET_INVALID_EN;
   boolean_t dataLob = 0; 
   boolean_t schemaLob = 0;


   /* Get the info of the DATASET instance. */
   FNC_GetDatasetInfo((*dataset_instance), &max_length, &in_line_length, &schema_length, &raw_data_length, &dataset_storage, &dataLob, &schemaLob);
	
   if (dataLob == 1)
	  {
	    LOB_LOCATOR inLOB;
	    LOB_CONTEXT_ID id;
	    FNC_LobLength_t readlen, actualInputLength;
	    int trunc_err = 0;
	    BYTE *bufPtr = result;
     int buffer_size = 0;

		   FNC_GetDatasetInputLob((int)*dataset_instance, &inLOB);
     FNC_LobOpen(inLOB, &id, 0, 0);
     buffer_size = FNC_GetLobLength(inLOB);

     while (FNC_LobRead(id, bufPtr, buffer_size, &readlen) == 0 && !trunc_err)
     {
        bufPtr += readlen;
        memcpy(result,bufPtr,readlen);
     }
     FNC_LobClose(id);
	  }
}

The following is sample output:

/*if data is not a LOB, there will be no output*/

SELECT (getLobData (avroFile) RETURNS VARBYTE(1000)) FROM datasetTable;

Result:

>