AmpereMeter - Example self-announcing webserver which controls …

Users » dirkx » Code » AmpereMeter

Dirk-Willem van Gulik (NXP/mbed) / Mbed 2 deprecated AmpereMeter

Example self-announcing webserver which controls a servo through a smallHTML userinterface.

services/mysql/MySQLClient.h@0:a259777c45a3, 2010-08-14 (annotated)

Committer:: dirkx
Date:: Sat Aug 14 15:56:01 2010 +0000
Revision:: 0:a259777c45a3

Who changed what in which revision?

User	Revision	Line number	New contents of line
dirkx	0:a259777c45a3	1
dirkx	0:a259777c45a3	2	/*
dirkx	0:a259777c45a3	3	Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
dirkx	0:a259777c45a3	4
dirkx	0:a259777c45a3	5	Permission is hereby granted, free of charge, to any person obtaining a copy
dirkx	0:a259777c45a3	6	of this software and associated documentation files (the "Software"), to deal
dirkx	0:a259777c45a3	7	in the Software without restriction, including without limitation the rights
dirkx	0:a259777c45a3	8	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
dirkx	0:a259777c45a3	9	copies of the Software, and to permit persons to whom the Software is
dirkx	0:a259777c45a3	10	furnished to do so, subject to the following conditions:
dirkx	0:a259777c45a3	11
dirkx	0:a259777c45a3	12	The above copyright notice and this permission notice shall be included in
dirkx	0:a259777c45a3	13	all copies or substantial portions of the Software.
dirkx	0:a259777c45a3	14
dirkx	0:a259777c45a3	15	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
dirkx	0:a259777c45a3	16	IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
dirkx	0:a259777c45a3	17	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
dirkx	0:a259777c45a3	18	AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
dirkx	0:a259777c45a3	19	LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
dirkx	0:a259777c45a3	20	OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
dirkx	0:a259777c45a3	21	THE SOFTWARE.
dirkx	0:a259777c45a3	22	*/
dirkx	0:a259777c45a3	23
dirkx	0:a259777c45a3	24	#ifndef MYSQL_CLIENT_H
dirkx	0:a259777c45a3	25	#define MYSQL_CLIENT_H
dirkx	0:a259777c45a3	26
dirkx	0:a259777c45a3	27	#include "if/net/net.h"
dirkx	0:a259777c45a3	28	#include "api/TCPSocket.h"
dirkx	0:a259777c45a3	29	#include "api/DNSRequest.h"
dirkx	0:a259777c45a3	30	#include "mbed.h"
dirkx	0:a259777c45a3	31
dirkx	0:a259777c45a3	32	#include <string>
dirkx	0:a259777c45a3	33	using std::string;
dirkx	0:a259777c45a3	34
dirkx	0:a259777c45a3	35	#include <map>
dirkx	0:a259777c45a3	36	using std::map;
dirkx	0:a259777c45a3	37
dirkx	0:a259777c45a3	38	typedef unsigned char byte;
dirkx	0:a259777c45a3	39
dirkx	0:a259777c45a3	40	enum MySQLResult
dirkx	0:a259777c45a3	41	{
dirkx	0:a259777c45a3	42	MYSQL_OK,
dirkx	0:a259777c45a3	43	MYSQL_PROCESSING,
dirkx	0:a259777c45a3	44	MYSQL_PRTCL,
dirkx	0:a259777c45a3	45	MYSQL_SETUP, //Not properly configured
dirkx	0:a259777c45a3	46	MYSQL_DNS, //Could not resolve name
dirkx	0:a259777c45a3	47	MYSQL_AUTHFAILED, //Auth failure
dirkx	0:a259777c45a3	48	MYSQL_READY, //Ready to send commands
dirkx	0:a259777c45a3	49	MYSQL_SQL, //SQL Error
dirkx	0:a259777c45a3	50	MYSQL_TIMEOUT, //Connection timeout
dirkx	0:a259777c45a3	51	MYSQL_CONN //Connection error
dirkx	0:a259777c45a3	52	};
dirkx	0:a259777c45a3	53
dirkx	0:a259777c45a3	54	class MySQLClient : protected NetService
dirkx	0:a259777c45a3	55	{
dirkx	0:a259777c45a3	56	public:
dirkx	0:a259777c45a3	57	MySQLClient();
dirkx	0:a259777c45a3	58	virtual ~MySQLClient();
dirkx	0:a259777c45a3	59
dirkx	0:a259777c45a3	60	//High Level setup functions
dirkx	0:a259777c45a3	61	MySQLResult open(Host& host, const string& user, const string& password, const string& db, void (*pMethod)(MySQLResult)); //Non blocking
dirkx	0:a259777c45a3	62	template<class T>
dirkx	0:a259777c45a3	63	MySQLResult open(Host& host, const string& user, const string& password, const string& db, T* pItem, void (T::*pMethod)(MySQLResult)) //Non blocking
dirkx	0:a259777c45a3	64	{
dirkx	0:a259777c45a3	65	setOnResult(pItem, pMethod);
dirkx	0:a259777c45a3	66	setup(host, user, password, db);
dirkx	0:a259777c45a3	67	return MYSQL_PROCESSING;
dirkx	0:a259777c45a3	68	}
dirkx	0:a259777c45a3	69
dirkx	0:a259777c45a3	70	MySQLResult sql(string& sqlCommand);
dirkx	0:a259777c45a3	71
dirkx	0:a259777c45a3	72	MySQLResult exit();
dirkx	0:a259777c45a3	73
dirkx	0:a259777c45a3	74	void setOnResult( void (*pMethod)(MySQLResult) );
dirkx	0:a259777c45a3	75	class CDummy;
dirkx	0:a259777c45a3	76	template<class T>
dirkx	0:a259777c45a3	77	void setOnResult( T* pItem, void (T::*pMethod)(MySQLResult) )
dirkx	0:a259777c45a3	78	{
dirkx	0:a259777c45a3	79	m_pCb = NULL;
dirkx	0:a259777c45a3	80	m_pCbItem = (CDummy*) pItem;
dirkx	0:a259777c45a3	81	m_pCbMeth = (void (CDummy::*)(MySQLResult)) pMethod;
dirkx	0:a259777c45a3	82	}
dirkx	0:a259777c45a3	83
dirkx	0:a259777c45a3	84	void setTimeout(int ms);
dirkx	0:a259777c45a3	85
dirkx	0:a259777c45a3	86	virtual void poll(); //Called by NetServices
dirkx	0:a259777c45a3	87
dirkx	0:a259777c45a3	88	protected:
dirkx	0:a259777c45a3	89	void resetTimeout();
dirkx	0:a259777c45a3	90
dirkx	0:a259777c45a3	91	void init();
dirkx	0:a259777c45a3	92	void close();
dirkx	0:a259777c45a3	93
dirkx	0:a259777c45a3	94	void setup(Host& host, const string& user, const string& password, const string& db); //Setup connection, make DNS Req if necessary
dirkx	0:a259777c45a3	95	void connect(); //Start Connection
dirkx	0:a259777c45a3	96
dirkx	0:a259777c45a3	97	void handleHandshake();
dirkx	0:a259777c45a3	98	void sendAuth();
dirkx	0:a259777c45a3	99
dirkx	0:a259777c45a3	100	void handleAuthResult();
dirkx	0:a259777c45a3	101	void sendAuth323();
dirkx	0:a259777c45a3	102
dirkx	0:a259777c45a3	103	void sendCommand(byte command, byte* arg, int len);
dirkx	0:a259777c45a3	104	void handleCommandResult();
dirkx	0:a259777c45a3	105
dirkx	0:a259777c45a3	106	void readData(); //Copy to buf
dirkx	0:a259777c45a3	107	void writeData(); //Copy from buf
dirkx	0:a259777c45a3	108
dirkx	0:a259777c45a3	109	void onTCPSocketEvent(TCPSocketEvent e);
dirkx	0:a259777c45a3	110	void onDNSReply(DNSReply r);
dirkx	0:a259777c45a3	111	void onResult(MySQLResult r); //Called when exchange completed or on failure
dirkx	0:a259777c45a3	112	void onTimeout(); //Connection has timed out
dirkx	0:a259777c45a3	113
dirkx	0:a259777c45a3	114	private:
dirkx	0:a259777c45a3	115	CDummy* m_pCbItem;
dirkx	0:a259777c45a3	116	void (CDummy::*m_pCbMeth)(MySQLResult);
dirkx	0:a259777c45a3	117
dirkx	0:a259777c45a3	118	void (*m_pCb)(MySQLResult);
dirkx	0:a259777c45a3	119
dirkx	0:a259777c45a3	120	TCPSocket* m_pTCPSocket;
dirkx	0:a259777c45a3	121
dirkx	0:a259777c45a3	122	Timer m_watchdog;
dirkx	0:a259777c45a3	123	int m_timeout;
dirkx	0:a259777c45a3	124
dirkx	0:a259777c45a3	125	DNSRequest* m_pDnsReq;
dirkx	0:a259777c45a3	126
dirkx	0:a259777c45a3	127	bool m_closed;
dirkx	0:a259777c45a3	128
dirkx	0:a259777c45a3	129	enum MySQLStep
dirkx	0:a259777c45a3	130	{
dirkx	0:a259777c45a3	131	// MYSQL_INIT,
dirkx	0:a259777c45a3	132	MYSQL_HANDSHAKE,
dirkx	0:a259777c45a3	133	MYSQL_AUTH,
dirkx	0:a259777c45a3	134	MYSQL_COMMANDS,
dirkx	0:a259777c45a3	135	MYSQL_CLOSED
dirkx	0:a259777c45a3	136	};
dirkx	0:a259777c45a3	137
dirkx	0:a259777c45a3	138	//Parameters
dirkx	0:a259777c45a3	139	Host m_host;
dirkx	0:a259777c45a3	140
dirkx	0:a259777c45a3	141	string m_user;
dirkx	0:a259777c45a3	142	string m_password;
dirkx	0:a259777c45a3	143	string m_db;
dirkx	0:a259777c45a3	144
dirkx	0:a259777c45a3	145	//Low-level buffers & state-machine
dirkx	0:a259777c45a3	146	MySQLStep m_state;
dirkx	0:a259777c45a3	147
dirkx	0:a259777c45a3	148	byte* m_buf;
dirkx	0:a259777c45a3	149	byte* m_pPos;
dirkx	0:a259777c45a3	150	int m_len;
dirkx	0:a259777c45a3	151	int m_size;
dirkx	0:a259777c45a3	152
dirkx	0:a259777c45a3	153	int m_packetId;
dirkx	0:a259777c45a3	154
dirkx	0:a259777c45a3	155	};
dirkx	0:a259777c45a3	156
dirkx	0:a259777c45a3	157	#endif

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	14 Aug 2010
Imports:	49
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	2
Followers:	1

services/mysql/MySQLClient.h@0:a259777c45a3, 2010-08-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning