Add sqlite3 files
This commit is contained in:
Ron Pedde
parent
3a6ec603a1
commit
f1acc3bc88
|
|
@ -0,0 +1,474 @@
|
|||
/*
|
||||
* $Id$
|
||||
* sqlite2-specific db implementation
|
||||
*
|
||||
* Copyright (C) 2005 Ron Pedde (ron@pedde.com)
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 2 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||
*/
|
||||
|
||||
/*
|
||||
* This file handles sqlite2 databases. SQLite2 databases
|
||||
* should have a dsn of:
|
||||
*
|
||||
* sqlite2:/path/to/folder
|
||||
*
|
||||
* The actual db will be appended to the passed path.
|
||||
*/
|
||||
|
||||
#ifdef HAVE_CONFIG_H
|
||||
# include "config.h"
|
||||
#endif
|
||||
|
||||
#define _XOPEN_SOURCE 500
|
||||
|
||||
#include <errno.h>
|
||||
#include <limits.h>
|
||||
#include <pthread.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <sqlite3.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include "err.h"
|
||||
#include "db-generic.h"
|
||||
#include "db-sql.h"
|
||||
#include "db-sql-sqlite3.h"
|
||||
|
||||
#ifndef TRUE
|
||||
# define TRUE 1
|
||||
# define FALSE 0
|
||||
#endif
|
||||
|
||||
|
||||
/* Globals */
|
||||
static sqlite3 *db_sqlite3_songs; /**< Database that holds the mp3 info */
|
||||
static pthread_mutex_t db_sqlite3_mutex = PTHREAD_MUTEX_INITIALIZER; /**< sqlite not reentrant */
|
||||
static sqlite3_stmt *db_sqlite3_stmt;
|
||||
static int db_sqlite3_reload=0;
|
||||
static char *db_sqlite3_enum_query;
|
||||
static int db_sqlite3_in_enum=0;
|
||||
static char **db_sqlite3_row = NULL;
|
||||
|
||||
static char db_sqlite3_path[PATH_MAX + 1];
|
||||
|
||||
#define DB_SQLITE3_VERSION 8
|
||||
|
||||
|
||||
/* Forwards */
|
||||
void db_sqlite3_lock(void);
|
||||
void db_sqlite3_unlock(void);
|
||||
extern char *db_sqlite3_initial;
|
||||
|
||||
/**
|
||||
* lock the db_mutex
|
||||
*/
|
||||
void db_sqlite3_lock(void) {
|
||||
int err;
|
||||
|
||||
if((err=pthread_mutex_lock(&db_sqlite3_mutex))) {
|
||||
DPRINTF(E_FATAL,L_DB,"cannot lock sqlite lock: %s\n",strerror(err));
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* unlock the db_mutex
|
||||
*/
|
||||
void db_sqlite3_unlock(void) {
|
||||
int err;
|
||||
|
||||
if((err=pthread_mutex_unlock(&db_sqlite3_mutex))) {
|
||||
DPRINTF(E_FATAL,L_DB,"cannot unlock sqlite3 lock: %s\n",strerror(err));
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
char *db_sqlite3_vmquery(char *fmt,va_list ap) {
|
||||
return sqlite3_vmprintf(fmt,ap);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
void db_sqlite3_vmfree(char *query) {
|
||||
sqlite3_free(query);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* open a sqlite3 database
|
||||
*
|
||||
* @param dsn the full dns to the database
|
||||
* (sqlite3:/path/to/database)
|
||||
*
|
||||
* @returns DB_E_SUCCESS on success
|
||||
*/
|
||||
int db_sqlite3_open(char **pe, char *dsn) {
|
||||
int ver;
|
||||
int err;
|
||||
|
||||
snprintf(db_sqlite3_path,sizeof(db_sqlite3_path),"%s/songs.db",dsn);
|
||||
|
||||
db_sqlite3_lock();
|
||||
if(sqlite3_open(db_sqlite3_path,&db_sqlite3_songs) != SQLITE_OK) {
|
||||
db_get_error(pe,DB_E_SQL_ERROR,sqlite3_errmsg(db_sqlite3_songs));
|
||||
DPRINTF(E_LOG,L_DB,"db_sqlite3_open: %s (%s)\n",*pe,
|
||||
db_sqlite3_path);
|
||||
db_sqlite3_unlock();
|
||||
return DB_E_SQL_ERROR;
|
||||
}
|
||||
|
||||
sqlite3_busy_timeout(db_sqlite3_songs,30000); /* 30 seconds */
|
||||
db_sqlite3_unlock();
|
||||
|
||||
err = db_sql_fetch_int(pe,&ver,"select value from config where "
|
||||
"term='version'");
|
||||
if(err != DB_E_SUCCESS) {
|
||||
if(pe) { free(*pe); }
|
||||
/* we'll catch this on the init */
|
||||
DPRINTF(E_LOG,L_DB,"Can't get db version. New database?\n");
|
||||
} else if(ver != DB_SQLITE3_VERSION) {
|
||||
DPRINTF(E_FATAL,L_DB,"Can't upgrade database!\n");
|
||||
}
|
||||
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
/**
|
||||
* close the database
|
||||
*/
|
||||
int db_sqlite3_close(void) {
|
||||
db_sqlite3_lock();
|
||||
sqlite3_close(db_sqlite3_songs);
|
||||
db_sqlite3_unlock();
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
/**
|
||||
* execute a throwaway query against the database, disregarding
|
||||
* the outcome
|
||||
*
|
||||
* @param pe db error structure
|
||||
* @param loglevel error level to return if the query fails
|
||||
* @param fmt sprintf-style arguements
|
||||
*
|
||||
* @returns DB_E_SUCCESS on success
|
||||
*/
|
||||
int db_sqlite3_exec(char **pe, int loglevel, char *fmt, ...) {
|
||||
va_list ap;
|
||||
char *query;
|
||||
int err;
|
||||
char *perr;
|
||||
|
||||
va_start(ap,fmt);
|
||||
query=sqlite3_vmprintf(fmt,ap);
|
||||
va_end(ap);
|
||||
|
||||
DPRINTF(E_DBG,L_DB,"Executing: %s\n",query);
|
||||
|
||||
db_sqlite3_lock();
|
||||
err=sqlite3_exec(db_sqlite3_songs,query,NULL,NULL,&perr);
|
||||
if(err != SQLITE_OK) {
|
||||
db_get_error(pe,DB_E_SQL_ERROR,perr);
|
||||
|
||||
DPRINTF(loglevel == E_FATAL ? E_LOG : loglevel,L_DB,"Query: %s\n",
|
||||
query);
|
||||
DPRINTF(loglevel,L_DB,"Error: %s\n",perr);
|
||||
sqlite3_free(perr);
|
||||
} else {
|
||||
DPRINTF(E_DBG,L_DB,"Rows: %d\n",sqlite3_changes(db_sqlite3_songs));
|
||||
}
|
||||
sqlite3_free(query);
|
||||
|
||||
db_sqlite3_unlock();
|
||||
|
||||
if(err != SQLITE_OK)
|
||||
return DB_E_SQL_ERROR;
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
/**
|
||||
* start enumerating rows in a select
|
||||
*/
|
||||
int db_sqlite3_enum_begin(char **pe, char *fmt, ...) {
|
||||
va_list ap;
|
||||
int err;
|
||||
const char *ptail;
|
||||
|
||||
if(!db_sqlite3_in_enum) {
|
||||
va_start(ap, fmt);
|
||||
db_sqlite3_lock();
|
||||
db_sqlite3_enum_query = sqlite3_vmprintf(fmt,ap);
|
||||
va_end(ap);
|
||||
}
|
||||
|
||||
DPRINTF(E_DBG,L_DB,"Executing: %s\n",db_sqlite3_enum_query);
|
||||
db_sqlite3_in_enum=1;
|
||||
|
||||
err=sqlite3_prepare(db_sqlite3_songs,db_sqlite3_enum_query,0,
|
||||
&db_sqlite3_stmt,&ptail);
|
||||
|
||||
if(err != SQLITE_OK) {
|
||||
db_get_error(pe,DB_E_SQL_ERROR,sqlite3_errmsg(db_sqlite3_songs));
|
||||
db_sqlite3_in_enum=0;
|
||||
db_sqlite3_unlock();
|
||||
sqlite3_free(db_sqlite3_enum_query);
|
||||
return DB_E_SQL_ERROR;
|
||||
}
|
||||
|
||||
/* otherwise, we leave the db locked while we walk through the enums */
|
||||
if(db_sqlite3_row)
|
||||
free(db_sqlite3_row);
|
||||
db_sqlite3_row=NULL;
|
||||
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
/**
|
||||
* fetch the next row
|
||||
*
|
||||
* @param pe error string, if result isn't DB_E_SUCCESS
|
||||
* @param pr pointer to a row struct
|
||||
*
|
||||
* @returns DB_E_SUCCESS with *pr=NULL when end of table,
|
||||
* DB_E_SUCCESS with a valid row when more data,
|
||||
* DB_E_* on error
|
||||
*/
|
||||
int db_sqlite3_enum_fetch(char **pe, SQL_ROW *pr) {
|
||||
int err;
|
||||
int cols;
|
||||
int idx;
|
||||
int counter=10;
|
||||
|
||||
while(counter--) {
|
||||
err=sqlite3_step(db_sqlite3_stmt);
|
||||
if(err != SQLITE_BUSY)
|
||||
break;
|
||||
usleep(100);
|
||||
}
|
||||
|
||||
if(err == SQLITE_DONE) {
|
||||
*pr = NULL;
|
||||
if(db_sqlite3_row)
|
||||
free(db_sqlite3_row);
|
||||
db_sqlite3_row = NULL;
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
if(err == SQLITE_ROW) {
|
||||
cols = sqlite3_column_count(db_sqlite3_stmt);
|
||||
|
||||
if(!db_sqlite3_row) {
|
||||
/* gotta alloc space */
|
||||
db_sqlite3_row = (char**)malloc((sizeof(char*)) * cols);
|
||||
if(!db_sqlite3_row)
|
||||
DPRINTF(E_FATAL,L_DB,"Malloc error\n");
|
||||
}
|
||||
|
||||
for(idx=0; idx < cols; idx++) {
|
||||
db_sqlite3_row[idx] = sqlite3_column_text(db_sqlite3_stmt,idx);
|
||||
}
|
||||
|
||||
*pr = db_sqlite3_row;
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
if(db_sqlite3_row)
|
||||
free(db_sqlite3_row);
|
||||
db_sqlite3_row = NULL;
|
||||
|
||||
db_get_error(pe,DB_E_SQL_ERROR,sqlite3_errmsg(db_sqlite3_songs));
|
||||
return DB_E_SQL_ERROR;
|
||||
}
|
||||
|
||||
/**
|
||||
* end the db enumeration
|
||||
*/
|
||||
int db_sqlite3_enum_end(char **pe) {
|
||||
int err;
|
||||
|
||||
db_sqlite3_in_enum=0;
|
||||
if(db_sqlite3_row)
|
||||
free(db_sqlite3_row);
|
||||
db_sqlite3_row = NULL;
|
||||
sqlite3_free(db_sqlite3_enum_query);
|
||||
|
||||
err = sqlite3_finalize(db_sqlite3_stmt);
|
||||
if(err != SQLITE_OK) {
|
||||
db_get_error(pe,DB_E_SQL_ERROR,sqlite3_errmsg(db_sqlite3_songs));
|
||||
db_sqlite3_unlock();
|
||||
return DB_E_SQL_ERROR;
|
||||
}
|
||||
|
||||
db_sqlite3_unlock();
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
/**
|
||||
* restart the enumeration
|
||||
*/
|
||||
int db_sqlite3_enum_restart(char **pe) {
|
||||
return db_sqlite3_enum_begin(pe,NULL);
|
||||
}
|
||||
|
||||
|
||||
int db_sqlite3_event(int event_type) {
|
||||
switch(event_type) {
|
||||
|
||||
case DB_SQL_EVENT_STARTUP: /* this is a startup with existing songs */
|
||||
db_sqlite3_exec(NULL,E_FATAL,"vacuum");
|
||||
db_sqlite3_reload=0;
|
||||
break;
|
||||
|
||||
case DB_SQL_EVENT_FULLRELOAD: /* either a fresh load or force load */
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop index idx_path");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop index idx_songid");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop index idx_playlistid");
|
||||
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table songs");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table playlists");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table playlistitems");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table config");
|
||||
|
||||
db_sqlite3_exec(NULL,E_DBG,"vacuum");
|
||||
|
||||
db_sqlite3_exec(NULL,E_DBG,db_sqlite3_initial);
|
||||
db_sqlite3_reload=1;
|
||||
break;
|
||||
|
||||
case DB_SQL_EVENT_SONGSCANSTART:
|
||||
if(db_sqlite3_reload) {
|
||||
db_sqlite3_exec(NULL,E_FATAL,"pragma synchronous = off");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"begin transaction");
|
||||
} else {
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table updated");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"create temp table updated (id int)");
|
||||
db_sqlite3_exec(NULL,E_DBG,"drop table plupdated");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"create temp table plupdated(id int)");
|
||||
}
|
||||
break;
|
||||
|
||||
case DB_SQL_EVENT_SONGSCANEND:
|
||||
if(db_sqlite3_reload) {
|
||||
db_sqlite3_exec(NULL,E_FATAL,"commit transaction");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"create index idx_path on songs(path)");
|
||||
db_sqlite3_exec(NULL,E_DBG,"delete from config where term='rescan'");
|
||||
} else {
|
||||
db_sqlite3_exec(NULL,E_FATAL,"delete from songs where id not in (select id from updated)");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"update songs set force_update=0");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"drop table updated");
|
||||
}
|
||||
break;
|
||||
|
||||
case DB_SQL_EVENT_PLSCANSTART:
|
||||
db_sqlite3_exec(NULL,E_FATAL,"begin transaction");
|
||||
break;
|
||||
|
||||
case DB_SQL_EVENT_PLSCANEND:
|
||||
db_sqlite3_exec(NULL,E_FATAL,"end transaction");
|
||||
|
||||
if(db_sqlite3_reload) {
|
||||
db_sqlite3_exec(NULL,E_FATAL,"pragma synchronous=normal");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"create index idx_songid on playlistitems(songid)");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"create index idx_playlistid on playlistitems(playlistid)");
|
||||
|
||||
} else {
|
||||
db_sqlite3_exec(NULL,E_FATAL,"delete from playlists where "
|
||||
"((type=%d) OR (type=%d)) and "
|
||||
"id not in (select id from plupdated)",
|
||||
PL_STATICFILE,PL_STATICXML);
|
||||
db_sqlite3_exec(NULL,E_FATAL,"delete from playlistitems where "
|
||||
"playlistid not in (select distinct "
|
||||
"id from playlists)");
|
||||
db_sqlite3_exec(NULL,E_FATAL,"drop table plupdated");
|
||||
}
|
||||
break;
|
||||
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
return DB_E_SUCCESS;
|
||||
}
|
||||
|
||||
char *db_sqlite3_initial =
|
||||
"create table songs (\n"
|
||||
" id INTEGER PRIMARY KEY NOT NULL,\n"
|
||||
" path VARCHAR(4096) UNIQUE NOT NULL,\n"
|
||||
" fname VARCHAR(255) NOT NULL,\n"
|
||||
" title VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" artist VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" album VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" genre VARCHAR(255) DEFAULT NULL,\n"
|
||||
" comment VARCHAR(4096) DEFAULT NULL,\n"
|
||||
" type VARCHAR(255) DEFAULT NULL,\n"
|
||||
" composer VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" orchestra VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" conductor VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" grouping VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" url VARCHAR(1024) DEFAULT NULL,\n"
|
||||
" bitrate INTEGER DEFAULT 0,\n"
|
||||
" samplerate INTEGER DEFAULT 0,\n"
|
||||
" song_length INTEGER DEFAULT 0,\n"
|
||||
" file_size INTEGER DEFAULT 0,\n"
|
||||
" year INTEGER DEFAULT 0,\n"
|
||||
" track INTEGER DEFAULT 0,\n"
|
||||
" total_tracks INTEGER DEFAULT 0,\n"
|
||||
" disc INTEGER DEFAULT 0,\n"
|
||||
" total_discs INTEGER DEFAULT 0,\n"
|
||||
" bpm INTEGER DEFAULT 0,\n"
|
||||
" compilation INTEGER DEFAULT 0,\n"
|
||||
" rating INTEGER DEFAULT 0,\n"
|
||||
" play_count INTEGER DEFAULT 0,\n"
|
||||
" data_kind INTEGER DEFAULT 0,\n"
|
||||
" item_kind INTEGER DEFAULT 0,\n"
|
||||
" description INTEGER DEFAULT 0,\n"
|
||||
" time_added INTEGER DEFAULT 0,\n"
|
||||
" time_modified INTEGER DEFAULT 0,\n"
|
||||
" time_played INTEGER DEFAULT 0,\n"
|
||||
" db_timestamp INTEGER DEFAULT 0,\n"
|
||||
" disabled INTEGER DEFAULT 0,\n"
|
||||
" sample_count INTEGER DEFAULT 0,\n"
|
||||
" force_update INTEGER DEFAULT 0,\n"
|
||||
" codectype VARCHAR(5) DEFAULT NULL,\n"
|
||||
" idx INTEGER NOT NULL\n"
|
||||
");\n"
|
||||
"create table config (\n"
|
||||
" term VARCHAR(255) NOT NULL,\n"
|
||||
" subterm VARCHAR(255) DEFAULT NULL,\n"
|
||||
" value VARCHAR(1024) NOT NULL\n"
|
||||
");\n"
|
||||
"create table playlistitems (\n"
|
||||
" id INTEGER PRIMARY KEY NOT NULL,\n"
|
||||
" playlistid INTEGER NOT NULL,\n"
|
||||
" songid INTEGER NOT NULL\n"
|
||||
");\n"
|
||||
"create table playlists (\n"
|
||||
" id INTEGER PRIMARY KEY NOT NULL,\n"
|
||||
" title VARCHAR(255) NOT NULL,\n"
|
||||
" type INTEGER NOT NULL,\n"
|
||||
" items INTEGER NOT NULL,\n"
|
||||
" query VARCHAR(1024),\n"
|
||||
" db_timestamp INTEGER NOT NULL,\n"
|
||||
" path VARCHAR(4096),\n"
|
||||
" idx INTEGER NOT NULL\n"
|
||||
");\n"
|
||||
"insert into config values ('version','','8');\n"
|
||||
"insert into playlists values (1,'Library',1,0,'1',0,'',0);\n";
|
||||
|
||||
|
||||
|
|
@ -0,0 +1,42 @@
|
|||
/*
|
||||
* $Id$
|
||||
* sqlite2-specific db implementation
|
||||
*
|
||||
* Copyright (C) 2005 Ron Pedde (ron@pedde.com)
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 2 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||
*/
|
||||
|
||||
#ifndef _DB_SQL_SQLITE3_
|
||||
#define _DB_SQL_SQLITE3_
|
||||
|
||||
extern int db_sqlite3_open(char **pe, char *dsn);
|
||||
extern int db_sqlite3_close(void);
|
||||
|
||||
/* simple utility functions */
|
||||
extern int db_sqlite3_exec(char **pe, int loglevel, char *fmt, ...);
|
||||
extern char *db_sqlite3_vmquery(char *fmt,va_list ap);
|
||||
extern void db_sqlite3_vmfree(char *query);
|
||||
|
||||
/* walk through a table */
|
||||
extern int db_sqlite3_enum_begin(char **pe, char *fmt, ...);
|
||||
extern int db_sqlite3_enum_fetch(char **pe, SQL_ROW *pr);
|
||||
extern int db_sqlite3_enum_end(char **pe);
|
||||
extern int db_sqlite3_enum_restart(char **pe);
|
||||
|
||||
extern int db_sqlite3_event(int event_type);
|
||||
|
||||
#endif /* _DB_SQL_SQLITE3_ */
|
||||
|
||||
Loading…
Reference in New Issue