RowsetToSQL.h File Reference

#include "python/PyRep.h"

Include dependency graph for RowsetToSQL.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	ReaderColumnContentDesc
	Helper class for column description. More...

Functions
template<typename _Reader >
void	ClassifyColumnTypes (std::vector< ReaderColumnContentDesc > &into, _Reader &reader)
	Classifies columns using ReaderColumnContentDesc. More...
template<typename _Reader >
bool	ReaderToSQL (const char *table_name, const char *key_field, FILE *out, _Reader &reader)
	Dumps rowset to SQL. More...

Variables
const size_t	INSERT_QUERY_ROW_LIMIT

Function Documentation

template<typename _Reader >

void ClassifyColumnTypes	(	std::vector< ReaderColumnContentDesc > &	into,
		_Reader &	reader
	)

Classifies columns using ReaderColumnContentDesc.

Parameters

[out]	into	Array of ReaderColumnContentDesc objects, which receive column descriptions.
[in]	reader	Rowset reader to use.

Definition at line 95 of file RowsetToSQL.h.

{
    const size_t cc = reader.columnCount();

    into.clear();
    into.resize( cc );

    typename _Reader::iterator cur, end;
    cur = reader.begin();
    end = reader.end();
    for(; cur != end; ++cur)
        for( size_t col = 0; col < cc; ++col )
            into[col].Process( cur.GetType( col ) );
}

template<typename _Reader >

bool ReaderToSQL	(	const char *	table_name,
		const char *	key_field,
		FILE *	out,
		_Reader &	reader
	)

Dumps rowset to SQL.

Parameters

[in]	table_name	Name of table to be created.
[in]	key_field	Key field of table.
[out]	out	Output file.
[in]	reader	Rowset reader to use.

Definition at line 119 of file RowsetToSQL.h.

References INSERT_QUERY_ROW_LIMIT, ReaderColumnContentDesc::nullString(), sLog, and ReaderColumnContentDesc::typeString().

{
    const size_t cc = reader.columnCount();

    const size_t key_col = reader.FindColumn( key_field );
    if( cc == key_col )
    {
        sLog.Error( "ReaderToSQL", "Unable to find key column '%s'.", key_field );
        return false;
    }

    std::vector<ReaderColumnContentDesc> types;
    ClassifyColumnTypes<_Reader>( types, reader );

    fprintf( out,
             "--- %s schema ---\n"
             "\n"
             "CREATE TABLE `%s` (\n",
             table_name,
             table_name
    );

    std::string field_list;
    for( size_t col = 0; col < cc; ++col )
    {
        const char* colName = reader.columnName( col );
        const ReaderColumnContentDesc& colDesc = types[col];

        fprintf( out,
                 "%s  `%s` %s %s%s",
                 ( 0 != col ? ",\n" : "" ),
                 colName,
                 colDesc.typeString(),
                 colDesc.nullString(),
                 ( key_col == col ? " PRIMARY KEY" : "" )
        );

        if( 0 != col  )
            field_list += ",";
        field_list += "`";
        field_list += colName;
        field_list += "`";
    }

    fprintf( out,
             "%s\n"
             ");\n"
             "\n"
             "--- end %s schema ---\n"
             "\n"
             "--- %s data ---\n"
             "\n",
             ( NULL == key_field ? ",\n  PRIMARY KEY()" : "" ),
             table_name,
             table_name
    );

    typename _Reader::iterator cur, end;
    cur = reader.begin();
    end = reader.end();
    for( size_t rowIndex = 0; cur != end; ++cur, ++rowIndex )
    {
        if( 0 == ( rowIndex % INSERT_QUERY_ROW_LIMIT ) )
        {
            if( 0 != rowIndex )
                fprintf( out, ";\n" );

            fprintf( out, "INSERT INTO `%s`(%s) VALUES ", table_name, field_list.c_str() );
        }
        else
            fprintf( out, "," );

        fprintf( out, "(" );
        for( size_t col = 0; col < cc; ++col )
        {
            if( col != 0 )
                fprintf( out, "," );

            fprintf( out, "%s", cur.GetAsString( col ).c_str() );
        }
        fprintf( out, ")" );
    }

    fprintf( out,
             ";\n"
             "\n"
             "--- end %s data ---\n",
             table_name
    );

    return true;
}

Here is the call graph for this function:

Variable Documentation

const size_t INSERT_QUERY_ROW_LIMIT

The largest amount of rows to be inserted by single query.

Definition at line 30 of file RowsetToSQL.cpp.

Referenced by ReaderToSQL().