stocksql.h

用GTK+做用户界面 股票每日分时行情用数据库管理——MYSQL 软件应用方式客户端/服务器模式 基于TCP/IP的C/S通信模式 实现STOCK

#ifndef __STOCKSQL__H

#define __STOCKSQL__H

#include "gmclient.h"
#define STOCKDATABASE "stockdata"
#define DAYKLINEDATABASE "stockday"
#define STOCKFSDATABASE "stockfs"
#define STOCKTRACEDATABASE "stocktrace"
#define MINKLINEDATABASE "stockmin"

#define STOCKINITTBL "stockinit"
#define SHNAMETBL "shnametbl"
#define SZNAMETBL "sznametbl"
#define SHGPMXTBL "shgpmx"
#define SZGPMXTBL "szgpmx"


class stockSql
{
  protected:
     MYSQL stsql;
     int sqlflag;
     int shnametblsum;
     int sznametblsum;
     int getnametblflag;

     char curstockcode[10];
     char curstockname[20];
     int curstocksum;
     int getklineflag;
  
     int getfsflag;
     int curfslinesum;
     
  public:
     stockSql();
     ~stockSql();
     int connectStockSql();
     int connectStockSql(char *host,char *user,char *pass,char  *database,int port,char *socket,int flag);
     void closeStockSql();
     char *stockSqlError();
     
//获取股票数据操作,包括日线,分时,明细,分笔等数据
     int getSqlStockData(char *code);  

//建立股票系统数据库
     int createStockDatabase();
     int dropStockDatabase();
     int isExistStockDatabase();
     
//股票初始化表操作
     int createInitTable();
     int dropInitTable();
     int isExistInitTable();
     int updateInitData(STOCKINIT data);
     int getSqlInitData();

//股票名称表操作
     int createNameTblTable(int bz);
     int dropNameTblTable(int bz);
     int isExistNameTblTable(int bz);
     int selectNameTbl();
     int insertNameTblData(int bz,int num,STOCKNAMETBL *data);
     int deleteNameTblData(int bz);
     int getSqlShNameTbl();
     int getSqlSzNameTbl();
     int getSqlNameTbl();

//股票日K线操作
     int createDayKlineDatabase();
     int dropDayKlineDatabase();
     int isExistDayKlineDatabase();
     int createDayKlineTable(char *code);
     int dropDayKlineTable(char *code);
     int selectDayKlineTable(char *code);
     int insertDayKlineData(char *code,int num,STOCK *data);
     int isExistDayKlineTable(char *code);
     int deleteDayKlineData(char *code);
     int deleteDayKlineData(char *code,int data); 
     int getSqlDayKline(char *code);

//股票分钟K线操作
     int createMinKlineDatabase();
     int dropMinKlineDatabase();
     int isExistMinKlineDatabase();


//股票明细表操作
     int createGpmxTable(int bz);
     int dropGpmxTable(int bz);
     int isExistGpmxTable(int bz);
     int selectGpmxTable(int bz);
     int insertGpmxData(int bz,STOCKGPMX data);
     int updateGpmxData(int bz,STOCKGPMX data);
     int insertGpmxDataFromNameTbl(int bz);
     int deleteGpmxData(int bz);
     int getSqlGpmxData(int bz,char *code);
     STOCKGPMX *getSqlGpmxdata(int bz,char *field,int start,int end);
     int insertGpmxDataFromNameTblWithZsp();

//取股票排行榜列表数据
     int getSqlGpmxListData(int bz,int order,int start);
     
//分时数据操作
     int createFsDatabase();
     int dropFsDatabase();
     int isExistFsDatabase();
     int createFsTable(char *code);
     int dropFsTable(char *code);
     int selectFsTable(char *code);
     int insertFsData(char *code,int num,STOCKFS *data);
     int isExistFsTable(char *code);
     int deleteFsData(char *code);
     int deleteFsData(char *code,int time); 
     int getSqlFsData(char *code);
     int quickCreateFsTable(char *code);
     int quickDeleteFsData(char *code);
     int selectFsDatabase();

//分笔成交数据操作
     int createTraceDatabase();
     int dropTraceDatabase();
     int isExistTraceDatabase();
     int createTraceTable(char *code);
     int dropTraceTable(char *code);
     int selectTraceTable(char *code);
     int insertTraceData(char *code,int num,STOCKTRACE *data);
     int isExistTraceTable(char *code);
     int deleteTraceData(char *code);
     int deleteTraceData(char *code,int time); 
     int getSqlTraceData(char *code);
     int quickDeleteTraceData(char *code);
     int quickCreateTraceTable(char *code);
     int selectTraceDatabase();

};

extern stockSql *stocksql;


#endif