mqtt/src/accmqtt.c - diff

Return to accmqtt.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

version 1.1.2.4, 2011/11/24 01:13:27	version 1.1.2.5, 2011/11/28 22:28:08
Line 1	Line 1
#include "global.h"	#include "global.h"


	extern const char sql_schema[];


/*	/*
* mqtt_rtlm_log() Log database connection message	* mqtt_rtlm_log() Log database connection message
*	*
Line 36 mqtt_rtlm_open(sl_config *cfg)	Line 39 mqtt_rtlm_open(sl_config *cfg)
if (!cfg)	if (!cfg)
return NULL;	return NULL;

	sqlite3_config(SQLITE_CONFIG_SERIALIZED);

str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("name"));	str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("name"));
if (!str) {	if (!str) {
mqtt_rtlm_log("Error:: Unknown database name ...\n");	mqtt_rtlm_log("Error:: Unknown database name ...\n");
return NULL;	return NULL;
}	}

if (sqlite3_open_v2(str, &sql, SQLITE_OPEN_READONLY, NULL)) {	if (sqlite3_open_v2(str, &sql, SQLITE_OPEN_READWRITE \| SQLITE_OPEN_CREATE, NULL)) {
MQTT_RTLM_LOG(sql);	MQTT_RTLM_LOG(sql);
sqlite3_close(sql);	sqlite3_close(sql);
return NULL;	return NULL;
}	}

	if (sqlite3_exec(sql, sql_schema, NULL, NULL, NULL)) {
	MQTT_RTLM_LOG(sql);
	sqlite3_close(sql);
	return NULL;
	}
return sql;	return sql;
}	}