這里說的SQL函數(shù),是指可在SQL語句中使用的函數(shù),如常見的 count(), sum(), avg(), min(), max() 等。?
在 sqlite 數(shù)據(jù)庫中,SQL函數(shù)被分為兩大類,一類稱作“Scalar function”,一類稱作“Aggregate function”。Scalar 和 Aggregate 實在不太清楚該怎么翻譯,而其含義,也難于用言語表達(dá),大概屬于只可意會不可言傳的情況。通俗來說,Scalar函數(shù)基本等同于C/C++函數(shù),而上面提到的 count(), sum() 等函數(shù)則屬于Aggregate函數(shù)。Aggregate函數(shù)不是根據(jù)參數(shù)直接得出結(jié)果,而是綜合了符合條件的所有記錄才最終計算出結(jié)果。
在 sqlite 中創(chuàng)建自定義SQL函數(shù),需涉及以下接口函數(shù):
int sqlite3_create_function(
? sqlite3 *db,
? const char *zFunctionName,
? int nArg,
? int eTextRep,
? void *pApp,
? void (*xFunc)(sqlite3_context*,int,sqlite3_value**),
? void (*xStep)(sqlite3_context*,int,sqlite3_value**),
? void (*xFinal)(sqlite3_context*)
);
void *sqlite3_user_data(sqlite3_context*);
void *sqlite3_aggregate_context(sqlite3_context*, int nBytes);
const void *sqlite3_value_blob(sqlite3_value*);
int sqlite3_value_bytes(sqlite3_value*);
int sqlite3_value_bytes16(sqlite3_value*);
double sqlite3_value_double(sqlite3_value*);
int sqlite3_value_int(sqlite3_value*);
sqlite3_int64 sqlite3_value_int64(sqlite3_value*);
const unsigned char *sqlite3_value_text(sqlite3_value*);
const void *sqlite3_value_text16(sqlite3_value*);
const void *sqlite3_value_text16le(sqlite3_value*);
const void *sqlite3_value_text16be(sqlite3_value*);
int sqlite3_value_type(sqlite3_value*);
int sqlite3_value_numeric_type(sqlite3_value*);
void sqlite3_result_blob(sqlite3_context*, const void*, int, void(*)(void*));
void sqlite3_result_double(sqlite3_context*, double);
void sqlite3_result_error(sqlite3_context*, const char*, int);
void sqlite3_result_error16(sqlite3_context*, const void*, int);
void sqlite3_result_error_toobig(sqlite3_context*);
void sqlite3_result_error_nomem(sqlite3_context*);
void sqlite3_result_error_code(sqlite3_context*, int);
void sqlite3_result_int(sqlite3_context*, int);
void sqlite3_result_int64(sqlite3_context*, sqlite3_int64);
void sqlite3_result_null(sqlite3_context*);
void sqlite3_result_text(sqlite3_context*, const char*, int, void(*)(void*));
void sqlite3_result_text16(sqlite3_context*, const void*, int, void(*)(void*));
void sqlite3_result_text16le(sqlite3_context*, const void*, int,void(*)(void*));
void sqlite3_result_text16be(sqlite3_context*, const void*, int,void(*)(void*));
void sqlite3_result_value(sqlite3_context*, sqlite3_value*);
void sqlite3_result_zeroblob(sqlite3_context*, int n);
要編寫sqlite3_create_function()所需的三個函數(shù)xFunc(), xStep(), xFinal(),不得不使用上面一堆接口函數(shù),比較復(fù)雜的說。如果僅僅是單純的將以上函數(shù)一一對應(yīng)到EF中,無疑是把復(fù)雜的工作轉(zhuǎn)稼給用戶,意義不大。(值得一提的是,在易語言的sqlite支持庫中,因為沒有找到比較優(yōu)雅的解決方案,未提供創(chuàng)建自定義SQL函數(shù)的功能。) 通過對sqlite api進(jìn)行包裝和再加工,我們在“易語言.飛揚(yáng)”中提供了簡潔易用的、面向?qū)ο蟮摹?yōu)雅的操作接口,在很大程度上簡化了創(chuàng)建自定義SQL函數(shù)的工作。
在“易語言.飛揚(yáng)”中,要創(chuàng)建一個“Scalar function”,只需調(diào)用 SqliteDB.RegSQLScalarFunc(),傳入一個實現(xiàn)了接口 SQLScalarFunction 的對象即可:
public?interface?SQLScalarFunction
{
????public?文本?取函數(shù)名稱();
????public?整數(shù)?取參數(shù)個數(shù)();
????public?通用型,整數(shù)?執(zhí)行(通用型[]?參數(shù));
}
用戶的工作主要集中在接口方法“通用型,整數(shù)?執(zhí)行(通用型[]?參數(shù))”中(對應(yīng)前面提到的xFunc),只需根據(jù)通用型數(shù)組參數(shù)計算出結(jié)果并返回即可。在這之前通過調(diào)用sqlite3_value_*系列函數(shù)獲取SQL參數(shù),以及在這之后調(diào)用sqlite3_result_*系列函數(shù)將結(jié)果反饋到sqlite的工作,全部由類庫代勞。用戶接口非常簡潔。
在“易語言.飛揚(yáng)”中,要創(chuàng)建一個“Aggregate function”,只需調(diào)用 SqliteDB.RegSQLAggregateFunc(),傳入一個實現(xiàn)了接口 SQLAggregateFunction 的對象即可:
public?interface?SQLAggregateFunction
{
????public?文本?取函數(shù)名稱();
????public?整數(shù)?取參數(shù)個數(shù)();
????public?SQLAggregateExecutor?創(chuàng)建執(zhí)行者();
}
public?interface?SQLAggregateExecutor
{
????public?通用型,整數(shù)?單步執(zhí)行(通用型[]?參數(shù));
????public?通用型,整數(shù)?最終執(zhí)行();
}
在一個Aggregate function被調(diào)用時,將自動調(diào)用“SQLAggregateFunction.創(chuàng)建執(zhí)行者()”為該函數(shù)創(chuàng)建一個“執(zhí)行者”對象(實現(xiàn)接口SQLAggregateExecutor)。為什么要創(chuàng)建“執(zhí)行者”對象呢?因為Aggregate function是“上下文有關(guān)的”,每個函數(shù)調(diào)用都需要單獨(dú)維護(hù)各自的上下文信息。接口SQLAggregateExecutor中的方法“單步執(zhí)行”“最終執(zhí)行”分別對應(yīng)前面提到的xStep,xFinal,聰明的您也許已經(jīng)猜測到了。
“易語言.飛揚(yáng)”sqlite類庫(sqlite.efn)提供的以上接口,簡潔易用、通俗易懂、面向?qū)ο蟆?yōu)雅大方,完全擺脫了sqlite api 的影子,是對原有接口的精心再加工,充分體現(xiàn)了我們“將復(fù)雜的事情簡單化”的決心。
(?注,以上涉及的類型名稱和方法名稱中英混用,也許是需要最終調(diào)整和完善的地方。)
根據(jù)以上接口,我們可以很輕松的實現(xiàn)自已版本的 sum() 函數(shù)——mysum():
public?class?MySum?<interfaces?=?SQLAggregateFunction>
{
????public?文本?取函數(shù)名稱()?{?返回?"mysum";?}
????public?整數(shù)?取參數(shù)個數(shù)()?{?返回?1;?}
????public?SQLAggregateExecutor?創(chuàng)建執(zhí)行者()?{?返回?new?MySumExecutor();?}
????class?MySumExecutor?<interfaces?=?SQLAggregateExecutor>
????{
????????private?int?_sum?=?0;
????????public?通用型,整數(shù)?單步執(zhí)行(通用型[]?參數(shù))
????????{
????????????_sum?+=?參數(shù)[0];
????????}
????????public?通用型,整數(shù)?最終執(zhí)行()?{?返回?(_sum,0);?}
????}
}