Subversion Repositories mdb

/*

 * Copyright (C) 2015 by Andreas Theofilu <andreas@theosys.at>

 *

 * All rights reserved. No warranty, explicit or implicit, provided.

 *

 * NOTICE:  All information contained herein is, and remains

 * the property of Andreas Theofilu and his suppliers, if any.

 * The intellectual and technical concepts contained

 * herein are proprietary to Andreas Theofilu and its suppliers and

 * may be covered by European and Foreign Patents, patents in process,

 * and are protected by trade secret or copyright law.

 * Dissemination of this information or reproduction of this material

 * is strictly forbidden unless prior written permission is obtained

 * from Andreas Theofilu.

 */

#include <stdio.h>

#include <string.h>

#include <strings.h>

#include <unistd.h>

#include <stdlib.h>

#include <ctype.h>

#include <math.h>

#include <syslog.h>

#include <errno.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <fcntl.h>

#include <sqlite3.h>

#include "config.h"

#include "helplib.h"

#include "user.h"

#include "play.h"

#include "search.h"

int searchTerm(int s1, const char *type, const char *term, int start, int length)

{

	char query[1024], field[128], hv0[128], buffer[8192];

	char fname[256];

	sqlite3 *db;

	int rc, id, total, pos, line;

	sqlite3_stmt *res;

	char id3_title[256], id3_artist[256], id3_album[256], id3_genre[256];

	char *title, *artist, *album;

	strcpy(fname, configs.home);

	strcat(fname, MUSICDB);

	rc = sqlite3_open(fname, &db);

	if (rc)

	{

		syslog(LOG_WARNING, "Error opening database %s: %s", fname, sqlite3_errmsg(db));

		strcpy(query, "ERROR:USER:Error opening database;");

		write (s1, query, strlen(query));

		return FALSE;

	}

	memset(field, 0, sizeof(field));

	if (!strcasecmp(type, "TITLE"))

		sprintf(field, "title like \"%%%s%%\"", term);

	else if (!strcasecmp(type, "ARTIST"))

		sprintf(field, "interpret like \"%%%s%%\"", term);

	else if (!strcasecmp(type, "ALBUM"))

		sprintf(field, "album like \"%%%s%%\"", term);

	else if (!strcasecmp(type, "GENRE"))

		sprintf(field, "genre like \"%%%s%%\"", term);

	strcpy (query, "select count(*) from musicdb where ");

	strcat (query, field);

	if (sqlite3_prepare(db, query, -1, &res, NULL) != SQLITE_OK)

	{

		syslog(LOG_DAEMON, "Error preparing SQL statement [%s]: %s", query, sqlite3_errmsg(db));

		strcpy(query, "ERROR:SEARCH:Error preparing a SQL statement;");

		write(s1, query, strlen(query));

		return FALSE;

	}

	if ((rc = sqlite3_step(res)) == SQLITE_ROW)

	{

		total = sqlite3_column_int(res, 0);

		sprintf(hv0, "TOTAL:%d;", total);

		write (s1, hv0, strlen(hv0));

	}

	else

		total = 0;

	strcpy (query, "select id, title, interpret, album, genre from musicdb where ");

	strcat (query, field);

	if (sqlite3_prepare(db, query, -1, &res, NULL) != SQLITE_OK)

	{

		syslog(LOG_DAEMON, "Error preparing SQL statement [%s]: %s", query, sqlite3_errmsg(db));

		strcpy(query, "ERROR:SEARCH:Error preparing a SQL statement;");

		write(s1, query, strlen(query));

		return FALSE;

	}

	pos = 0;

	line = 1;

	while ((rc = sqlite3_step(res)) == SQLITE_ROW)

	{

		if (pos < (start - 1))

		{

			pos++;

			continue;

		}

		if (pos >= ((start - 1) + length))

			break;

		memset(id3_title, 0, sizeof(id3_title));

		memset(id3_artist, 0, sizeof(id3_artist));

		memset(id3_album, 0, sizeof(id3_album));

		memset(id3_genre, 0, sizeof(id3_genre));

		id = sqlite3_column_int(res, 0);

		strncpy(id3_title, (const char *)sqlite3_column_text(res, 1), sizeof(id3_title));

		strncpy(id3_artist, (const char *)sqlite3_column_text(res, 2), sizeof(id3_artist));

		strncpy(id3_album, (const char *)sqlite3_column_text(res, 3), sizeof(id3_album));

		strncpy(id3_genre, (const char *)sqlite3_column_text(res, 4), sizeof(id3_genre));

		title = urlencode(id3_title);

		artist = urlencode(id3_artist);

		album = urlencode(id3_album);

		if (title != NULL)

		{

			strncpy(id3_title, title, sizeof(id3_title));

			free(title);

		}

		if (artist != NULL)

		{

			strncpy(id3_artist, artist, sizeof(id3_artist));

			free(artist);

		}

		if (album != NULL)

		{

			strncpy(id3_album, album, sizeof(id3_album));

			free(album);

		}

		sprintf (buffer, "SEARCH:%s:%d:%d:%s:%s:%s:%s;", type, id, line, id3_title, id3_artist, id3_album, id3_genre);

		write (s1, buffer, strlen(buffer));

		pos++;

		line++;

	}

	sqlite3_finalize(res);

	sqlite3_close(db);

	return TRUE;

}