mysql_reader.h File Reference

serialize mysql data to package More...

#include "ypc/corecommon/package.h"
#include <boost/property_tree/json_parser.hpp>
#include <boost/property_tree/ptree.hpp>
#include <ff/net/middleware/ntpackage.h>
#include <ff/sql/mysql.hpp>
#include <ff/util/ntobject.h>
#include <fstream>
#include <iostream>
#include <memory>
#include <stdint.h>

Include dependency graph for mysql_reader.h:

Go to the source code of this file.

Classes
class	ypc::plugins::mysql_reader
class	ypc::plugins::typed_mysql_reader< T, Table >
struct	ypc::plugins::typed_mysql_reader< T, Table >::read_helper< NTObjType >
struct	ypc::plugins::typed_mysql_reader< T, Table >::read_helper<::ff::util::ntobject< ARGS... > >
struct	ypc::plugins::typed_mysql_reader< T, Table >::assign_helper< ARGS >
struct	ypc::plugins::typed_mysql_reader< T, Table >::assign_helper< ARGT >
struct	ypc::plugins::typed_mysql_reader< T, Table >::assign_helper< ARGT1, ARGT2, ARGS... >
struct	ypc::plugins::typed_mysql_reader< T, Table >::assign_package< RT >
struct	ypc::plugins::typed_mysql_reader< T, Table >::assign_package<::ff::util::ntobject< ARGS... > >

Macros
#define	impl_mysql_reader(type)

Functions
void *	create_item_reader (const char *extra_param, int len)
int	reset_for_read (void *handle)
int	read_item_data (void *handle, char *buf, int *len)
int	close_item_reader (void *handle)
uint64_t	get_item_number (void *handle)

Detailed Description

serialize mysql data to package

serialize data by index from the whole table and then cast to package

Author

YeeZTech

Date

2022-10-19

Version

2.0

Macro Definition Documentation

impl_mysql_reader

#define impl_mysql_reader

(

type

)

Value:

  void *create_item_reader(const char *extra_param, int len) {                 \
    try {                                                                      \
      ypc::plugins::mysql_reader *reader =                                     \
          new type(std::string(extra_param, len));                             \
      return reader;                                                           \
    } catch (const std::exception &e) {                                        \
      std::cout << "create_item_reader got: " << e.what() << std::endl;        \
      return nullptr;                                                          \
    }                                                                          \
  }                                                                            \
  int reset_for_read(void *handle) {                                           \
    ypc::plugins::mysql_reader *reader = (ypc::plugins::mysql_reader *)handle; \
    return reader->reset_for_read();                                           \
  }                                                                            \
  int read_item_data(void *handle, char *buf, int *len) {                      \
    ypc::plugins::mysql_reader *reader = (ypc::plugins::mysql_reader *)handle; \
    return reader->read_item_data(buf, len);                                   \
  }                                                                            \
  int close_item_reader(void *handle) {                                        \
    ypc::plugins::mysql_reader *reader = (ypc::plugins::mysql_reader *)handle; \
    reader->close_item_reader();                                               \
    delete reader;                                                             \
    return 0;                                                                  \
  }                                                                            \
                                                                               \
  uint64_t get_item_number(void *handle) {                                     \
    ypc::plugins::mysql_reader *reader = (ypc::plugins::mysql_reader *)handle; \
    return reader->get_item_number();                                          \
  }