OLD | NEW |
| (Empty) |
1 /* | |
2 ** 2014-06-13 | |
3 ** | |
4 ** The author disclaims copyright to this source code. In place of | |
5 ** a legal notice, here is a blessing: | |
6 ** | |
7 ** May you do good and not evil. | |
8 ** May you find forgiveness for yourself and forgive others. | |
9 ** May you share freely, never taking more than you give. | |
10 ** | |
11 ****************************************************************************** | |
12 ** | |
13 ** This SQLite extension implements SQL functions readfile() and | |
14 ** writefile(). | |
15 */ | |
16 #include "sqlite3ext.h" | |
17 SQLITE_EXTENSION_INIT1 | |
18 #include <stdio.h> | |
19 | |
20 /* | |
21 ** Implementation of the "readfile(X)" SQL function. The entire content | |
22 ** of the file named X is read and returned as a BLOB. NULL is returned | |
23 ** if the file does not exist or is unreadable. | |
24 */ | |
25 static void readfileFunc( | |
26 sqlite3_context *context, | |
27 int argc, | |
28 sqlite3_value **argv | |
29 ){ | |
30 const char *zName; | |
31 FILE *in; | |
32 long nIn; | |
33 void *pBuf; | |
34 | |
35 zName = (const char*)sqlite3_value_text(argv[0]); | |
36 if( zName==0 ) return; | |
37 in = fopen(zName, "rb"); | |
38 if( in==0 ) return; | |
39 fseek(in, 0, SEEK_END); | |
40 nIn = ftell(in); | |
41 rewind(in); | |
42 pBuf = sqlite3_malloc( nIn ); | |
43 if( pBuf && 1==fread(pBuf, nIn, 1, in) ){ | |
44 sqlite3_result_blob(context, pBuf, nIn, sqlite3_free); | |
45 }else{ | |
46 sqlite3_free(pBuf); | |
47 } | |
48 fclose(in); | |
49 } | |
50 | |
51 /* | |
52 ** Implementation of the "writefile(X,Y)" SQL function. The argument Y | |
53 ** is written into file X. The number of bytes written is returned. Or | |
54 ** NULL is returned if something goes wrong, such as being unable to open | |
55 ** file X for writing. | |
56 */ | |
57 static void writefileFunc( | |
58 sqlite3_context *context, | |
59 int argc, | |
60 sqlite3_value **argv | |
61 ){ | |
62 FILE *out; | |
63 const char *z; | |
64 sqlite3_int64 rc; | |
65 const char *zFile; | |
66 | |
67 zFile = (const char*)sqlite3_value_text(argv[0]); | |
68 if( zFile==0 ) return; | |
69 out = fopen(zFile, "wb"); | |
70 if( out==0 ) return; | |
71 z = (const char*)sqlite3_value_blob(argv[1]); | |
72 if( z==0 ){ | |
73 rc = 0; | |
74 }else{ | |
75 rc = fwrite(z, 1, sqlite3_value_bytes(argv[1]), out); | |
76 } | |
77 fclose(out); | |
78 sqlite3_result_int64(context, rc); | |
79 } | |
80 | |
81 | |
82 #ifdef _WIN32 | |
83 __declspec(dllexport) | |
84 #endif | |
85 int sqlite3_fileio_init( | |
86 sqlite3 *db, | |
87 char **pzErrMsg, | |
88 const sqlite3_api_routines *pApi | |
89 ){ | |
90 int rc = SQLITE_OK; | |
91 SQLITE_EXTENSION_INIT2(pApi); | |
92 (void)pzErrMsg; /* Unused parameter */ | |
93 rc = sqlite3_create_function(db, "readfile", 1, SQLITE_UTF8, 0, | |
94 readfileFunc, 0, 0); | |
95 if( rc==SQLITE_OK ){ | |
96 rc = sqlite3_create_function(db, "writefile", 2, SQLITE_UTF8, 0, | |
97 writefileFunc, 0, 0); | |
98 } | |
99 return rc; | |
100 } | |
OLD | NEW |