Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
G
gosqlite
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
gosqlite
Commits
4751f87d
Commit
4751f87d
authored
Jan 23, 2015
by
gwenn
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fix indentation.
parent
222ec3c2
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
95 additions
and
95 deletions
+95
-95
vtab.c
vtab.c
+95
-95
No files found.
vtab.c
View file @
4751f87d
...
...
@@ -9,153 +9,153 @@
typedef
struct
goVTab
goVTab
;
struct
goVTab
{
sqlite3_vtab
base
;
void
*
vTab
;
sqlite3_vtab
base
;
void
*
vTab
;
};
static
int
cXInit
(
sqlite3
*
db
,
void
*
pAux
,
int
argc
,
const
char
*
const
*
argv
,
sqlite3_vtab
**
ppVTab
,
char
**
pzErr
,
int
isCreate
)
{
void
*
vTab
=
goMInit
(
db
,
pAux
,
argc
,
(
char
**
)
argv
,
pzErr
,
isCreate
);
if
(
!
vTab
||
*
pzErr
)
{
return
SQLITE_ERROR
;
}
goVTab
*
pvTab
=
(
goVTab
*
)
sqlite3_malloc
(
sizeof
(
goVTab
));
if
(
!
pvTab
)
{
*
pzErr
=
sqlite3_mprintf
(
"%s"
,
"Out of memory"
);
return
SQLITE_NOMEM
;
}
memset
(
pvTab
,
0
,
sizeof
(
goVTab
));
pvTab
->
vTab
=
vTab
;
*
ppVTab
=
(
sqlite3_vtab
*
)
pvTab
;
*
pzErr
=
0
;
return
SQLITE_OK
;
void
*
vTab
=
goMInit
(
db
,
pAux
,
argc
,
(
char
**
)
argv
,
pzErr
,
isCreate
);
if
(
!
vTab
||
*
pzErr
)
{
return
SQLITE_ERROR
;
}
goVTab
*
pvTab
=
(
goVTab
*
)
sqlite3_malloc
(
sizeof
(
goVTab
));
if
(
!
pvTab
)
{
*
pzErr
=
sqlite3_mprintf
(
"%s"
,
"Out of memory"
);
return
SQLITE_NOMEM
;
}
memset
(
pvTab
,
0
,
sizeof
(
goVTab
));
pvTab
->
vTab
=
vTab
;
*
ppVTab
=
(
sqlite3_vtab
*
)
pvTab
;
*
pzErr
=
0
;
return
SQLITE_OK
;
}
static
inline
int
cXCreate
(
sqlite3
*
db
,
void
*
pAux
,
int
argc
,
const
char
*
const
*
argv
,
sqlite3_vtab
**
ppVTab
,
char
**
pzErr
)
{
return
cXInit
(
db
,
pAux
,
argc
,
argv
,
ppVTab
,
pzErr
,
1
);
return
cXInit
(
db
,
pAux
,
argc
,
argv
,
ppVTab
,
pzErr
,
1
);
}
static
inline
int
cXConnect
(
sqlite3
*
db
,
void
*
pAux
,
int
argc
,
const
char
*
const
*
argv
,
sqlite3_vtab
**
ppVTab
,
char
**
pzErr
)
{
return
cXInit
(
db
,
pAux
,
argc
,
argv
,
ppVTab
,
pzErr
,
0
);
}
static
inline
int
cXBestIndex
(
sqlite3_vtab
*
pVTab
,
sqlite3_index_info
*
info
)
{
// TODO
// TODO
return
SQLITE_OK
;
}
static
int
cXRelease
(
sqlite3_vtab
*
pVTab
,
int
isDestroy
)
{
char
*
pzErr
=
goVRelease
(((
goVTab
*
)
pVTab
)
->
vTab
,
isDestroy
);
if
(
pzErr
)
{
if
(
pVTab
->
zErrMsg
)
sqlite3_free
(
pVTab
->
zErrMsg
);
pVTab
->
zErrMsg
=
pzErr
;
return
SQLITE_ERROR
;
}
if
(
pVTab
->
zErrMsg
)
sqlite3_free
(
pVTab
->
zErrMsg
);
sqlite3_free
(
pVTab
);
return
SQLITE_OK
;
char
*
pzErr
=
goVRelease
(((
goVTab
*
)
pVTab
)
->
vTab
,
isDestroy
);
if
(
pzErr
)
{
if
(
pVTab
->
zErrMsg
)
sqlite3_free
(
pVTab
->
zErrMsg
);
pVTab
->
zErrMsg
=
pzErr
;
return
SQLITE_ERROR
;
}
if
(
pVTab
->
zErrMsg
)
sqlite3_free
(
pVTab
->
zErrMsg
);
sqlite3_free
(
pVTab
);
return
SQLITE_OK
;
}
static
inline
int
cXDisconnect
(
sqlite3_vtab
*
pVTab
)
{
return
cXRelease
(
pVTab
,
0
);
}
static
inline
int
cXDestroy
(
sqlite3_vtab
*
pVTab
)
{
return
cXRelease
(
pVTab
,
1
);
return
cXRelease
(
pVTab
,
1
);
}
typedef
struct
goVTabCursor
goVTabCursor
;
struct
goVTabCursor
{
sqlite3_vtab_cursor
base
;
void
*
vTabCursor
;
sqlite3_vtab_cursor
base
;
void
*
vTabCursor
;
};
static
int
cXOpen
(
sqlite3_vtab
*
pVTab
,
sqlite3_vtab_cursor
**
ppCursor
)
{
void
*
vTabCursor
=
goVOpen
(((
goVTab
*
)
pVTab
)
->
vTab
,
&
(
pVTab
->
zErrMsg
));
goVTabCursor
*
pCursor
=
(
goVTabCursor
*
)
sqlite3_malloc
(
sizeof
(
goVTabCursor
));
if
(
!
pCursor
)
{
return
SQLITE_NOMEM
;
}
memset
(
pCursor
,
0
,
sizeof
(
goVTabCursor
));
pCursor
->
vTabCursor
=
vTabCursor
;
*
ppCursor
=
(
sqlite3_vtab_cursor
*
)
pCursor
;
void
*
vTabCursor
=
goVOpen
(((
goVTab
*
)
pVTab
)
->
vTab
,
&
(
pVTab
->
zErrMsg
));
goVTabCursor
*
pCursor
=
(
goVTabCursor
*
)
sqlite3_malloc
(
sizeof
(
goVTabCursor
));
if
(
!
pCursor
)
{
return
SQLITE_NOMEM
;
}
memset
(
pCursor
,
0
,
sizeof
(
goVTabCursor
));
pCursor
->
vTabCursor
=
vTabCursor
;
*
ppCursor
=
(
sqlite3_vtab_cursor
*
)
pCursor
;
return
SQLITE_OK
;
}
static
int
setErrMsg
(
sqlite3_vtab_cursor
*
pCursor
,
char
*
pzErr
)
{
if
(
pCursor
->
pVtab
->
zErrMsg
)
sqlite3_free
(
pCursor
->
pVtab
->
zErrMsg
);
pCursor
->
pVtab
->
zErrMsg
=
pzErr
;
return
SQLITE_ERROR
;
if
(
pCursor
->
pVtab
->
zErrMsg
)
sqlite3_free
(
pCursor
->
pVtab
->
zErrMsg
);
pCursor
->
pVtab
->
zErrMsg
=
pzErr
;
return
SQLITE_ERROR
;
}
static
int
cXClose
(
sqlite3_vtab_cursor
*
pCursor
)
{
char
*
pzErr
=
goVClose
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
sqlite3_free
(
pCursor
);
char
*
pzErr
=
goVClose
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
sqlite3_free
(
pCursor
);
return
SQLITE_OK
;
}
static
int
cXFilter
(
sqlite3_vtab_cursor
*
pCursor
,
int
idxNum
,
const
char
*
idxStr
,
int
argc
,
sqlite3_value
**
argv
)
{
// TODO idxNum, idxStr, argc, argv are useless when cXBestIndex is empty
char
*
pzErr
=
goVFilter
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
// TODO idxNum, idxStr, argc, argv are useless when cXBestIndex is empty
char
*
pzErr
=
goVFilter
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
}
static
int
cXNext
(
sqlite3_vtab_cursor
*
pCursor
)
{
char
*
pzErr
=
goVNext
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
char
*
pzErr
=
goVNext
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
}
static
inline
int
cXEof
(
sqlite3_vtab_cursor
*
pCursor
)
{
return
goVEof
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
return
goVEof
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
);
}
static
int
cXColumn
(
sqlite3_vtab_cursor
*
pCursor
,
sqlite3_context
*
ctx
,
int
i
)
{
char
*
pzErr
=
goVColumn
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
,
ctx
,
i
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
char
*
pzErr
=
goVColumn
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
,
ctx
,
i
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
}
static
int
cXRowid
(
sqlite3_vtab_cursor
*
pCursor
,
sqlite3_int64
*
pRowid
)
{
char
*
pzErr
=
goVRowid
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
,
pRowid
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
char
*
pzErr
=
goVRowid
(((
goVTabCursor
*
)
pCursor
)
->
vTabCursor
,
pRowid
);
if
(
pzErr
)
{
return
setErrMsg
(
pCursor
,
pzErr
);
}
return
SQLITE_OK
;
}
static
sqlite3_module
goModule
=
{
0
,
/* iVersion */
cXCreate
,
/* xCreate - create a table */
cXConnect
,
/* xConnect - connect to an existing table */
cXBestIndex
,
/* xBestIndex - Determine search strategy */
cXDisconnect
,
/* xDisconnect - Disconnect from a table */
cXDestroy
,
/* xDestroy - Drop a table */
cXOpen
,
/* xOpen - open a cursor */
cXClose
,
/* xClose - close a cursor */
cXFilter
,
/* xFilter - configure scan constraints */
cXNext
,
/* xNext - advance a cursor */
cXEof
,
/* xEof */
cXColumn
,
/* xColumn - read data */
cXRowid
,
/* xRowid - read data */
0
,
/* iVersion */
cXCreate
,
/* xCreate - create a table */
cXConnect
,
/* xConnect - connect to an existing table */
cXBestIndex
,
/* xBestIndex - Determine search strategy */
cXDisconnect
,
/* xDisconnect - Disconnect from a table */
cXDestroy
,
/* xDestroy - Drop a table */
cXOpen
,
/* xOpen - open a cursor */
cXClose
,
/* xClose - close a cursor */
cXFilter
,
/* xFilter - configure scan constraints */
cXNext
,
/* xNext - advance a cursor */
cXEof
,
/* xEof */
cXColumn
,
/* xColumn - read data */
cXRowid
,
/* xRowid - read data */
// TODO
0
,
/* xUpdate - write data */
0
,
/* xBegin - begin transaction */
0
,
/* xSync - sync transaction */
0
,
/* xCommit - commit transaction */
0
,
/* xRollback - rollback transaction */
0
,
/* xFindFunction - function overloading */
0
,
/* xRename - rename the table */
0
,
/* xSavepoint */
0
,
/* xRelease */
0
/* xRollbackTo */
0
,
/* xUpdate - write data */
0
,
/* xBegin - begin transaction */
0
,
/* xSync - sync transaction */
0
,
/* xCommit - commit transaction */
0
,
/* xRollback - rollback transaction */
0
,
/* xFindFunction - function overloading */
0
,
/* xRename - rename the table */
0
,
/* xSavepoint */
0
,
/* xRelease */
0
/* xRollbackTo */
};
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment