Skip to content
GitLab
Commit e76c7527 authored by Jerry Clarke's avatar Jerry Clarke
Browse files

Adding HeavyData support for MySQL --- ignore password for now

parent c8e58e0c
Hide whitespace changes
Inline Side-by-side
libsrc/XdmfValuesMySQL.cxx 0 → 100644
View file @ e76c7527
/*******************************************************************/
/* XDMF */
/* eXtensible Data Model and Format */
/* */
/* Id : Id */
/* Date : $Date$ */
/* Version : $Revision$ */
/* */
/* Author: */
/* Jerry A. Clarke */
/* clarke@arl.army.mil */
/* US Army Research Laboratory */
/* Aberdeen Proving Ground, MD */
/* */
/* Copyright @ 2008 US Army Research Laboratory */
/* All Rights Reserved */
/* See Copyright.txt or http://www.arl.hpc.mil/ice for details */
/* */
/* This software is distributed WITHOUT ANY WARRANTY; without */
/* even the implied warranty of MERCHANTABILITY or FITNESS */
/* FOR A PARTICULAR PURPOSE. See the above copyright notice */
/* for more information. */
/* */
/*******************************************************************/
#include "XdmfValuesMySQL.h"
#include "XdmfDataStructure.h"
#include "XdmfArray.h"
#include "XdmfHDF.h"
#include "mysql.h"
XdmfValuesMySQL::XdmfValuesMySQL() {
this->Password = 0;
this->DataBase = 0;
this->Query = 0;
this->Server = 0;
this->User = 0;
this->SetFormat(XDMF_FORMAT_MYSQL);
this->SetServer("localhost");
this->SetUser("root");
}
XdmfValuesMySQL::~XdmfValuesMySQL() {
}
XdmfArray *
XdmfValuesMySQL::Read(XdmfArray *anArray){
XdmfArray *RetArray = anArray;
XdmfInt64 ResultLength, Fields, Rows, Index, NValues;
XdmfInt32 FieldIndex;
XdmfConstString Value;
MYSQL *Connection;
MYSQL_RES *Result;
MYSQL_FIELD *Field;
MYSQL_ROW Row;
this->SetDebug(1);
if(!this->DataDesc){
XdmfErrorMessage("DataDesc has not been set");
return(NULL);
}
// Allocate anArray if Necessary
if(!RetArray){
RetArray = new XdmfArray();
RetArray->CopyType(this->DataDesc);
RetArray->CopyShape(this->DataDesc);
// RetArray->CopySelection(this->DataDesc);
}
XdmfDebug("Accessing MySQL CDATA");
Value = this->Get("Query");
if(Value){
this->SetQuery(Value);
}else{
this->SetQuery(this->Get("CDATA"));
}
Value = this->Get("Server");
if(Value){
this->SetServer(Value);
}else{
this->SetServer("localhost");
}
Value = this->Get("User");
if(Value){
this->SetUser(Value);
}else{
this->SetUser("root");
}
Value = this->Get("Password");
if(Value){
this->SetPassword(Value);
}else{
this->Password = NULL;
}
Value = this->Get("DataBase");
if(Value){
this->SetDataBase(Value);
}else{
this->SetDataBase("Xdmf");
}
if(!(Connection = mysql_init(NULL))){
XdmfErrorMessage("Cannot Initialize MySQL");
return(NULL);
}
if(!mysql_real_connect(Connection, this->Server, this->User,
this->Password, this->DataBase, 0, NULL, 0)){
XdmfErrorMessage("Error Making MySQL Connection : " << mysql_error(Connection));
mysql_close(Connection);
return(NULL);
}
if(mysql_query(Connection, this->Query)){
XdmfErrorMessage("Using Query : " << this->Query);
XdmfErrorMessage("Error Making MySQL Query : " << mysql_error(Connection));
mysql_close(Connection);
return(NULL);
}
Result = mysql_use_result(Connection);
// Result = mysql_store_result(Connection);
Fields = mysql_num_fields(Result);
Rows = mysql_num_rows(Result);
XdmfDebug("Query " << this->Query << " Returned " << Fields << " Fields");
XdmfDebug("Query " << this->Query << " Returned " << Rows << " Rows");
NValues = this->DataDesc->GetSelectionSize();
// RetArray->SetNumberOfElements(Fields * Rows);
Index = 0;
while((Row = mysql_fetch_row(Result)) && (Index < NValues)){
for(FieldIndex = 0 ; FieldIndex < Fields ; FieldIndex++){
RetArray->SetValues(Index++, Row[FieldIndex]);
}
}
if(this->DataDesc->GetSelectionSize() != RetArray->GetNumberOfElements() ){
// Only Want Portion of anArray
XdmfArray *SrcArray;
XdmfInt64 SelectionSize = this->DataDesc->GetSelectionSize();
XdmfDebug("Selecting " << SelectionSize << " elements of XML CDATA");
SrcArray = RetArray->Clone();
RetArray->SetShape(1, &SelectionSize);
RetArray->SelectAll();
SrcArray->CopySelection(this->DataDesc);
XdmfDebug("Original Values = " << SrcArray->GetValues());
CopyArray(SrcArray, RetArray);
XdmfDebug("New Values = " << RetArray->GetValues());
delete SrcArray;
}
mysql_free_result(Result);
mysql_close(Connection);
return(RetArray);
}
XdmfInt32
XdmfValuesMySQL::Write(XdmfArray *anArray, XdmfConstString /*HeavyDataSetName*/){
XdmfConstString DataValues;
ostrstream StringOutput;
XdmfInt32 rank, r;
XdmfInt64 i, index, nelements, len, idims[XDMF_MAX_DIMENSION], dims[XDMF_MAX_DIMENSION];
if(!this->DataDesc ){
XdmfErrorMessage("DataDesc has not been set");
return(XDMF_FAIL);
}
if(!anArray){
XdmfErrorMessage("Array to Write is NULL");
return(XDMF_FAIL);
}
rank = this->DataDesc->GetShape(dims);
for(i = 0 ; i < rank ; i++){
idims[i] = dims[i];
}
// At most 10 values per line
len = MIN(dims[rank - 1], 10);
nelements = this->DataDesc->GetNumberOfElements();
index = 0;
StringOutput << endl;
while(nelements){
r = rank - 1;
len = MIN(len, nelements);
DataValues = anArray->GetValues(index, len);
StringOutput << DataValues << endl;
index += len;
nelements -= len;
dims[r] -= len;
// End of Smallest dimension ?
if(nelements && r && (dims[r] <= 0)){
// Reset
dims[r] = idims[r];
// Go Backwards thru dimensions
while(r){
r--;
dims[r]--;
// Is dim now 0
if(dims[r] <= 0){
// Add an Endl and keep going
StringOutput << endl;
dims[r] = idims[r];
}else{
// Still some left
break;
}
}
}
}
StringOutput << ends;
return(this->Set("CDATA", StringOutput.str()));
}
libsrc/XdmfValuesMySQL.h 0 → 100644
View file @ e76c7527
/*******************************************************************/
/* XDMF */
/* eXtensible Data Model and Format */
/* */
/* Id : Id */
/* Date : $Date$ */
/* Version : $Revision$ */
/* */
/* Author: */
/* Jerry A. Clarke */
/* clarke@arl.army.mil */
/* US Army Research Laboratory */
/* Aberdeen Proving Ground, MD */
/* */
/* Copyright @ 2008 US Army Research Laboratory */
/* All Rights Reserved */
/* See Copyright.txt or http://www.arl.hpc.mil/ice for details */
/* */
/* This software is distributed WITHOUT ANY WARRANTY; without */
/* even the implied warranty of MERCHANTABILITY or FITNESS */
/* FOR A PARTICULAR PURPOSE. See the above copyright notice */
/* for more information. */
/* */
/*******************************************************************/
#ifndef __XdmfValuesMySQL_h
#define __XdmfValuesMySQL_h
#include "XdmfValues.h"
//! Parent Class for handeling I/O of actual data for an XdmfDataItem
/*!
This is the class for access of values from a MySQL Database. By default, the
ValuesXML are in XML and handled XdmfValuesXML. Otherwise they're
handled by XdmfValuesXMLXXX (where XXX is the format). In this format (SQL)
the CDATA of the DataItem is an SQL Query into a MySQL Database
A MySQL XdmfDataItem Node Looks like :
\verbatim
<DataItem
Rank="1"
Dimensions="300"
Precision="4"
DataType="Float"
Format="MySQL"
DataBase="MnmiDB"
User="Xdmf"
Server="localhost">
SELECT * FROM Locations WHERE Time > 0.11
</DataItem>
\endverbatim
This DataItem
*/
class XDMF_EXPORT XdmfValuesMySQL : public XdmfValues {
public :
XdmfValuesMySQL();
virtual ~XdmfValuesMySQL();
XdmfConstString GetClassName() { return("XdmfValuesMySQL"); } ;
//! Read the Array from the External Representation
XdmfArray *Read(XdmfArray *Array=NULL);
//! Write the Array to the External Representation
XdmfInt32 Write(XdmfArray *Array, XdmfConstString HeavyDataSetName=NULL);
//! Get the Hostname of the MySQL Server
XdmfGetStringMacro(Server);
//! Get the Hostname of the MySQL Server
XdmfSetStringMacro(Server);
//! Get the User Name
XdmfGetStringMacro(User);
//! Get the User Name
XdmfSetStringMacro(User);
//! Get the Password
XdmfGetStringMacro(Password);
//! Get the Password
XdmfSetStringMacro(Password);
//! Get the DataBase Name
XdmfGetStringMacro(DataBase);
//! Get the DataBase Name
XdmfSetStringMacro(DataBase);
//! Get the Query
XdmfGetStringMacro(Query);
//! Get the Query
XdmfSetStringMacro(Query);
protected :
XdmfString Server;
XdmfString User;
XdmfString Password;
XdmfString DataBase;
XdmfString Query;
};
#endif
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment