AutoIpNetStack - Net stack with AutoIP enabled

Users » darran » Code » AutoIpNetStack

Darran Shepherd / Mbed 2 deprecated AutoIpNetStack

Net stack with AutoIP enabled

services/mysql/MySQLClient.h@0:ac21159e27f4, 2010-07-02 (annotated)

Committer:: darran
Date:: Fri Jul 02 17:21:58 2010 +0000
Revision:: 0:ac21159e27f4

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	02 Jul 2010
Imports:	2
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	1
Followers:	1

services/mysql/MySQLClient.h@0:ac21159e27f4, 2010-07-02 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning