csv_reader.h File Reference

serialize csv file to package More...

#include "csv.h"
#include "csv_read_assign_helper.h"
#include "ypc/corecommon/package.h"
#include <boost/property_tree/json_parser.hpp>
#include <boost/property_tree/ptree.hpp>
#include <ff/util/ntobject.h>
#include <fstream>
#include <iostream>
#include <memory>
#include <stdint.h>

Include dependency graph for csv_reader.h:

Go to the source code of this file.

Classes
class	ypc::plugins::csv_reader
struct	ypc::plugins::ntobject_size< NT >
struct	ypc::plugins::ntobject_size<::ff::util::ntobject< T1 > >
struct	ypc::plugins::ntobject_size<::ff::util::ntobject< T1, ARGS... > >
class	ypc::plugins::typed_csv_reader< T >

Macros
#define	impl_csv_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 csv file to package

serialize csv file line by line to m_stream and the cast to package

Author

YeeZTech

Date

2022-10-19

Version

2.0

Macro Definition Documentation

impl_csv_reader

#define impl_csv_reader

(

type

)

Value:

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