Создать функцию в Vertica

Я проверил множество источников, но cudnt получил результат.Создать функцию в Vertica

Как создать функцию в vertica для возврата количества всех сеансов в базе данных ?

Может кто-нибудь представить какую-либо идею или возможные варианты в этой теме.

2016-12-08 Ranjana Ghimire

создать C++ (count_it.cpp)

#include "Vertica.h" 
#include <time.h> 
#include <sstream> 
#include <iostream> 

using namespace Vertica; 
using namespace std; 

class Average : public AggregateFunction 
{ 
    virtual void initAggregate(ServerInterface &srvInterface, IntermediateAggs &aggs) 
    { 
     try { 
      VNumeric &sum = aggs.getNumericRef(0); 
      sum.setZero(); 

      vint &cnt = aggs.getIntRef(1); 
      cnt = 0; 
     } catch(exception& e) { 
      vt_report_error(0, "Exception while initializing intermediate aggregates: [%s]", e.what()); 
     } 
    } 

    void aggregate(ServerInterface &srvInterface, BlockReader &argReader, IntermediateAggs &aggs) 
    { 
     try { 
      VNumeric &sum = aggs.getNumericRef(0); 
      vint  &cnt = aggs.getIntRef(1); 

      do { 
       const VNumeric &input = argReader.getNumericRef(0); 
       if (!input.isNull()) { 
        sum.accumulate(&input); 
        sum.setZero(); 
        cnt++; 
       } 
      } while (argReader.next()); 
     } catch(exception& e) { 
      vt_report_error(0, "Exception while processing aggregate: [%s]", e.what()); 
     } 
    } 

    virtual void combine(ServerInterface &srvInterface,IntermediateAggs &aggs,MultipleIntermediateAggs &aggsOther) 
    { 
     try { 
      VNumeric  &mySum  = aggs.getNumericRef(0); 
      vint   &myCount = aggs.getIntRef(1); 

      do { 
       const VNumeric &otherSum = aggsOther.getNumericRef(0); 
       const vint  &otherCount = aggsOther.getIntRef(1); 

       mySum.accumulate(&otherSum); 
       mySum.setZero(); 
       myCount += otherCount; 

      } while (aggsOther.next()); 
     } catch(exception& e) { 
      vt_report_error(0, "Exception while combining intermediate aggregates: [%s]", e.what()); 
     } 
    } 

    virtual void terminate(ServerInterface &srvInterface, BlockWriter &resWriter, IntermediateAggs &aggs) 
    { 
     try { 
      const VerticaType &numtype = aggs.getTypeMetaData().getColumnType(0); 
      const VNumeric  &sum  = aggs.getNumericRef(0); 
      sum.setZero(); 

      uint64* tmp = (uint64*)malloc(numtype.getMaxSize()/sizeof(uint64)); 
      VNumeric cnt(tmp, numtype.getNumericPrecision(), numtype.getNumericScale()); 
      cnt.copy(aggs.getIntRef(1)); 
      VNumeric &out = resWriter.getNumericRef(); 
      if (cnt.isZero()) 
       out.setZero(); 
      else 
       out.add(&cnt,&sum); 
     } catch(exception& e) { 
      vt_report_error(0, "Exception while computing aggregate output: [%s]", e.what()); 
     } 
    } 

    InlineAggregate() 
}; 


class count_itFactory : public AggregateFunctionFactory 
{ 
    virtual void getPrototype(ServerInterface &srvfloaterface,ColumnTypes &argTypes,ColumnTypes &returnType) 
    { 
     argTypes.addNumeric(); 
     returnType.addNumeric(); 
    } 

    virtual void getReturnType(ServerInterface &srvfloaterface,const SizedColumnTypes &inputTypes,SizedColumnTypes &outputTypes) 
    { 
     int int_part = inputTypes.getColumnType(0).getNumericPrecision(); 
     int frac_part = inputTypes.getColumnType(0).getNumericScale(); 
     outputTypes.addNumeric(int_part+frac_part, frac_part); 
    } 

    virtual void getIntermediateTypes(ServerInterface &srvInterface,const SizedColumnTypes &inputTypes,SizedColumnTypes &intermediateTypeMetaData) 
    { 
     int int_part = inputTypes.getColumnType(0).getNumericIntegral(); 
     int frac_part = inputTypes.getColumnType(0).getNumericFractional(); 
     intermediateTypeMetaData.addNumeric(int_part+frac_part, frac_part); 
     intermediateTypeMetaData.addInt(); 
    } 

    virtual AggregateFunction *createAggregateFunction(ServerInterface &srvfloaterface) 
    { return vt_createFuncObject<Average>(srvfloaterface.allocator); } 

}; 

RegisterFactory(count_itFactory);

компилировать C++

g++ -D HAVE_LONG_INT_64 -I /opt/vertica/sdk/include -Wall -shared -Wno-unused-value -fPIC -o count_it.so /home/dbadmin/libs/count_it.cpp /opt/vertica/sdk/include/Vertica.cpp

создать библиотеку

CREATE LIBRARY count_it AS '/home/dbadmin/libs/count_it.so';

функции создания

CREATE AGGREGATE FUNCTION count_it AS LANGUAGE 'C++' NAME 'count_itFactory' LIBRARY count_it;

использовать функцию

select count_it(client_id) from sesions;

источник

2016-12-13 07:30:17

В этом ответе есть несколько ошибок: (1) сеансы, а не сеансы, (2) выделена память, но не освобождена, (3) malloc casted, (4) вы не контролируете, если malloc действительно выделяет память, (5) для агрегатных функций требуется Group by и т. д. Это прекрасный пример того, как НЕ писать код. – mauro

Вы можете создать UDX в Vertica, но у него нет дескриптора сеанса, поэтому вы можете получать доступ только к данным, открываемым через API. Данные сеанса не отображаются.

Для этого вам нужно выполнить запрос.

SELECT COUNT(*) FROM sessions;

источник

2016-12-08 18:13:23 woot

Я знаю об этом запросе. Просто я хочу попробовать функции, которые возвращают данные таблицы. –

Нельзя сделать, извините. В Vertica нет хранимых процедур, UDX не имеет дескриптора сеанса для запросов. Запрос - это ваш единственный выбор. – woot

Посмотреть этот пост что-то подобное:

SELECT 
node_name 
,user_name 
,'SELECT CLOSE_SESSION(''' || session_id || ''');' AS CloseSession 
,statement_start 
,(GETDATE() - statement_start)::INTERVAL AS current_statement_duration 
,REGEXP_REPLACE(current_statement,'[rnt]',' ') AS current_statement 
,session_id 
,transaction_id 
,statement_id 
,client_hostname 
,client_os 
,login_timestamp 
,runtime_priority 
,ssl_state 
,authentication_method 
,transaction_start 
,GETDATE() AS Today

ОТ v_monitor.sessions ORDER BY DESC current_statement_duration ;

Также вы можете получить больше информации с этого поста: Script to List Vertica Active Sessions

источник

2016-12-11 23:47:37

ответ

Смежные вопросы