53 VfsRootFile() =
default;
56 std::unique_ptr<ROOT::Internal::RRawFile> fRawFile;
65 VfsRootFile *
p =
reinterpret_cast<VfsRootFile *
>(pFile);
75 VfsRootFile *
p =
reinterpret_cast<VfsRootFile *
>(pFile);
105 VfsRootFile *
p =
reinterpret_cast<VfsRootFile *
>(pFile);
106 *
pSize =
p->fRawFile->GetSize();
183 VfsRootFile *
p =
new (pFile) VfsRootFile();
184 p->pFile.pMethods =
nullptr;
238 for (
int i = 0; i <
nBuf; ++i) {
277 *
prNow = i / 86400000.0;
291 vfs.szOsFile =
sizeof(VfsRootFile);
292 vfs.mxPathname = 2000;
332 : fType(
type), fIsActive(
false), fInteger(0), fReal(0.0), fText(), fBlob(), fNull(nullptr)
340 default:
throw std::runtime_error(
"Internal error");
357 throw std::runtime_error(
"Cannot register SQlite VFS in RSqliteDS");
385 for (
int i = 0; i <
colCount; ++i) {
406 throw std::runtime_error(
"Unexpected column decl type");
431 default:
throw std::runtime_error(
"Unhandled data type");
438RSqliteDS::~RSqliteDS()
451const std::vector<std::string> &RSqliteDS::GetColumnNames()
const
467 std::string
errmsg =
"The type selected for column \"";
469 errmsg +=
"\" does not correspond to column type, which is ";
471 throw std::runtime_error(
errmsg);
481std::vector<std::pair<ULong64_t, ULong64_t>> RSqliteDS::GetEntryRanges()
483 std::vector<std::pair<ULong64_t, ULong64_t>>
entryRanges;
500std::string RSqliteDS::GetTypeName(std::string_view
colName)
const
504 for (
unsigned i = 0; i <
N; ++i) {
509 throw std::runtime_error(
"Unknown column: " + std::string(
colName));
514bool RSqliteDS::HasColumn(std::string_view
colName)
const
521void RSqliteDS::Initialize()
526 throw std::runtime_error(
"SQlite error, reset");
529std::string RSqliteDS::GetLabel()
551 for (
unsigned i = 0; i <
N; ++i) {
575 default:
throw std::runtime_error(
"Unhandled column type");
583void RSqliteDS::SetNSlots(
unsigned int nSlots)
586 ::Warning(
"SetNSlots",
"Currently the SQlite data source faces performance degradation in multi-threaded mode. "
587 "Consider turning off IMT.");
596 std::string
errmsg =
"SQlite error: ";
597#if SQLITE_VERSION_NUMBER < 3007015
602 throw std::runtime_error(
errmsg);
unsigned long long ULong64_t
ROOT::Detail::TRangeCast< T, true > TRangeDynCast
TRangeDynCast is an adapter class that allows the typed iteration through a TCollection.
void Error(const char *location, const char *msgfmt,...)
Use this function in case an error occurred.
void Warning(const char *location, const char *msgfmt,...)
Use this function in warning situations.
winID h TVirtualViewer3D TVirtualGLPainter p
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h offset
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t index
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t type
R__EXTERN TRandom * gRandom
R__EXTERN TSystem * gSystem
static std::unique_ptr< RRawFile > Create(std::string_view url, ROptions options=ROptions())
Factory method that returns a suitable concrete implementation according to the transport in the url.
std::vector< void * > Record_t
static constexpr char const * fgTypeNames[]
Corresponds to the types defined in ETypes.
std::vector< std::string > fColumnNames
std::vector< ETypes > fColumnTypes
std::string GetTypeName(std::string_view colName) const final
Returns the C++ type for a given column name, implemented as a linear search through all the columns.
ETypes
All the types known to SQlite. Changes require changing fgTypeNames, too.
RSqliteDS(const std::string &fileName, const std::string &query)
Build the dataframe.
std::unique_ptr< Internal::RSqliteDSDataSet > fDataSet
void SqliteError(int errcode)
Helper function to throw an exception if there is a fatal sqlite error, e.g. an I/O error.
std::vector< Value_t > fValues
The data source is inherently single-threaded and returns only one row at a time. This vector holds t...
ROOT's RDataFrame offers a modern, high-level interface for analysis of data stored in TTree ,...
const_iterator begin() const
const_iterator end() const
virtual UInt_t Integer(UInt_t imax)
Returns a random integer uniformly distributed on the interval [ 0, imax-1 ].
virtual void Sleep(UInt_t milliSec)
Sleep milliSec milli seconds.
RDataFrame FromSqlite(std::string_view fileName, std::string_view query)
Factory method to create a SQlite RDataFrame.
tbb::task_arena is an alias of tbb::interface7::task_arena, which doesn't allow to forward declare tb...
The state of an open dataset in terms of the sqlite3 C library.
void * fPtr
Points to one of the values; an address to this pointer is returned by GetColumnReadersImpl.
std::vector< unsigned char > fBlob