csqlconnection.h

很好用的数据库连接组件

#ifndef CSQL_CONNECTION_H
#define CSQL_CONNECTION_H
#include "CSqlConnectionImpl.h" 
# if defined(_REENTRANT)
#include "mymutex.h"
#include "mymutexpool_p.h"
# endif
#include "csql.h"

class CSqlConnectionPrivate;
class CSqlConnection
{
public:
	~CSqlConnection ();

	bool open ();
	bool open (const string & user, const string & password);
	void close ();
	bool isOpen () const;
	bool isOpenError () const;

	CSqlQuery exec (const string & query = "") const;	//执行sql
	CSqlBcp   bcp(const string& table = "" ) const ;	// 开始bcp(包括绑定bind操作）
	CSqlError lastError () const;				//数据库错误

	virtual void setDatabaseName (const string & name);	//设置数据库名
	virtual void setUserName (const string & name);		//设置用户名
	virtual void setPassword (const string & password);	//设置密码
	virtual void setHostName (const string & host);		//设置server
	virtual void setPort (int p);				//设置断口
	virtual void setAppName( const string& appName );	//设置应用程序名
	virtual bool useDb (const string & db) const;		// use db
	string databaseName () const; 
	string userName () const;
	string password () const;
	string hostName () const;
	string driverName () const;
	string appName() const;
	int port () const;
	CSqlDriver *driver () const;
	static const char *const defaultConnection;
	/* 增加连接*/
	static CSqlConnection *addConnection (const string & type,
			    const string & connectionName = defaultConnection);
	/*检索连接*/
	static CSqlConnection *connection (const string & connectionName =
				 defaultConnection, bool open = true);
	/*删除连接*/
	static void removeConnection (const string & connectionName);
	/*判断连接是否存在*/
	static bool contains (const string & connectionName = defaultConnection);
protected:
	CSqlConnection (const string & type, const string & name);
private:
	void init (const string & type, const string & name);
	CSqlConnectionPrivate *d;
};
class CSqlConnectionPrivate 
{
public:
	CSqlConnectionPrivate():driver(NULL),port(-1)
	{
	}
	~CSqlConnectionPrivate()
	{
	}
	CSqlDriver *driver ;
	string dbname ;
	string uname ;
	string pword ;
	string hname ;
	string drvName ;
	string appName ;
	int port ;
};

#endif