Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Refractor code into C interface #44

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
44 changes: 44 additions & 0 deletions src/C_interface.jl
Original file line number Diff line number Diff line change
Expand Up @@ -26,3 +26,47 @@ end
function readstat_variable_get_index(variable::Ptr{Nothing})
return ccall((:readstat_variable_get_index, libreadstat), Cint, (Ptr{Nothing},), variable)
end

function readstat_variable_get_name(variable::Ptr{Nothing})
return unsafe_string(ccall((:readstat_variable_get_name, libreadstat), Cstring, (Ptr{Nothing},), variable))
end

function readstat_variable_get_type(variable::Ptr{Nothing})
return ccall((:readstat_variable_get_type, libreadstat), Cint, (Ptr{Nothing},), variable)
end

function readstat_variable_get_storage_width(variable::Ptr{Nothing})
return ccall((:readstat_variable_get_storage_width, libreadstat), Csize_t, (Ptr{Nothing},), variable)
end

function readstat_variable_get_measure(variable::Ptr{Nothing})
return ccall((:readstat_variable_get_measure, libreadstat), Cint, (Ptr{Nothing},), variable)
end

function readstat_variable_get_alignment(variable::Ptr{Nothing})
return ccall((:readstat_variable_get_alignment, libreadstat), Cint, (Ptr{Nothing},), variable)
end

function readstat_parser_free(parser::Ptr{Nothing})
return ccall((:readstat_parser_free, libreadstat), Nothing, (Ptr{Nothing},), parser)
end

function readstat_value_type(val::Value)
return ccall((:readstat_value_type, libreadstat), Cint, (Val,), val)
end

function readstat_parse(filename::String, type::Val{:dta}, parser::Ptr{Nothing}, ds::ReadStatDataFrame)
return ccall((:readstat_parse_dta, libreadstat), Int, (Ptr{Nothing}, Cstring, Any), parser, string(filename), ds)
end

function readstat_parse(filename::String, type::Val{:sav}, parser::Ptr{Nothing}, ds::ReadStatDataFrame)
return ccall((:readstat_parse_sav, libreadstat), Int, (Ptr{Nothing}, Cstring, Any), parser, string(filename), ds)
end

function readstat_parse(filename::String, type::Val{:por}, parser::Ptr{Nothing}, ds::ReadStatDataFrame)
return ccall((:readstat_parse_por, libreadstat), Int, (Ptr{Nothing}, Cstring, Any), parser, string(filename), ds)
end

function readstat_parse(filename::String, type::Val{:sas7bdat}, parser::Ptr{Nothing}, ds::ReadStatDataFrame)
return ccall((:readstat_parse_sas7bdat, libreadstat), Int, (Ptr{Nothing}, Cstring, Any), parser, string(filename), ds)
end
52 changes: 19 additions & 33 deletions src/ReadStat.jl
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ struct ReadStatValue
end
end

include("C_interface.jl")
const Value = ReadStatValue

mutable struct ReadStatDataFrame
data::Vector{Any}
Expand All @@ -81,6 +81,8 @@ mutable struct ReadStatDataFrame
String[], Dict{String, Dict{Any,String}}(), 0, 0, "", Dates.unix2datetime(0), 0)
end

include("C_interface.jl")

##############################################################################
##
## Julia functions
Expand All @@ -104,8 +106,7 @@ function handle_metadata!(metadata::Ptr{Nothing}, ds_ptr::Ptr{ReadStatDataFrame}
return Cint(0)
end

get_name(var::Ptr{Nothing}) = Symbol(unsafe_string(ccall((:readstat_variable_get_name, libreadstat),
Cstring, (Ptr{Nothing},), var)))
get_name(variable::Ptr{Nothing}) = Symbol(readstat_variable_get_name(variable))

function get_label(var::Ptr{Nothing})
ptr = ccall((:readstat_variable_get_label, libreadstat), Cstring, (Ptr{Nothing},), var)
Expand All @@ -117,8 +118,8 @@ function get_format(var::Ptr{Nothing})
ptr == C_NULL ? "" : unsafe_string(ptr)
end

function get_type(var::Ptr{Nothing})
data_type = ccall((:readstat_variable_get_type, libreadstat), Cint, (Ptr{Nothing},), var)
function get_type(variable::Ptr{Nothing})
data_type = readstat_variable_get_type(variable)

if data_type == READSTAT_TYPE_STRING
return String
Expand All @@ -136,12 +137,11 @@ function get_type(var::Ptr{Nothing})
return Nothing
end

get_storagewidth(var::Ptr{Nothing}) = ccall((:readstat_variable_get_storage_width, libreadstat),
Csize_t, (Ptr{Nothing},), var)
get_storagewidth(variable::Ptr{Nothing}) = readstat_variable_get_storage_width(variable)

get_measure(var::Ptr{Nothing}) = ccall((:readstat_variable_get_measure, libreadstat), Cint, (Ptr{Nothing},), var)
get_measure(variable::Ptr{Nothing}) = readstat_variable_get_measure(variable)

get_alignment(var::Ptr{Nothing}) = ccall((:readstat_variable_get_alignment, libreadstat), Cint, (Ptr{Nothing},), var)
get_alignment(variable::Ptr{Nothing}) = readstat_variable_get_measure(variable)

function handle_variable!(var_index::Cint, variable::Ptr{Nothing},
val_label::Cstring, ds_ptr::Ptr{ReadStatDataFrame})
Expand All @@ -162,11 +162,8 @@ function handle_variable!(var_index::Cint, variable::Ptr{Nothing},
return Cint(0)
end

const Value = ReadStatValue

function get_type(val::Value)
data_type = ccall((:readstat_value_type, libreadstat), Cint, (Value,), val)

data_type = readstat_value_type(val)
return [String, Int8, Int16, Int32, Float32, Float64, String][data_type + 1]
end

Expand Down Expand Up @@ -228,7 +225,7 @@ function handle_value_label!(val_labels::Cstring, value::Value, label::Cstring,
return Cint(0)
end

function read_data_file(filename::AbstractString, filetype::Type)
function read_data_file(filename::AbstractString, filetype::Val)
# initialize ds
ds = ReadStatDataFrame()
# initialize parser
Expand All @@ -253,26 +250,15 @@ function Parser()
return parser
end

for f in (:dta, :sav, :por, :sas7bdat)
valtype = Val{f}
# call respective parser
@eval begin
function parse_data_file!(ds::ReadStatDataFrame, parser,
filename::AbstractString, filetype::Type{$valtype})
retval = ccall(($(string(:readstat_parse_, f)), libreadstat),
Int, (Ptr{Nothing}, Cstring, Any),
parser, string(filename), ds)
ccall((:readstat_parser_free, libreadstat), Nothing, (Ptr{Nothing},), parser)
retval == 0 || error("Error parsing $filename: $retval")
end
end
end

for f in (:dta, :sav, :por, :sas7bdat)
valtype = Val{f}
# define read_dta that calls read(.., val{:dta}))
@eval $(Symbol(:read_, f))(filename::AbstractString) = read_data_file(filename, $valtype)
function parse_data_file!(ds::ReadStatDataFrame, parser::Ptr{Nothing}, filename::AbstractString, filetype::Val)
retval = readstat_parse(filename, filetype, parser, ds)
readstat_parser_free(parser)
retval == 0 || error("Error parsing $filename: $retval")
end

read_dta(filename::AbstractString) = read_data_file(filename, Val(:dta))
read_sav(filename::AbstractString) = read_data_file(filename, Val(:sav))
read_por(filename::AbstractString) = read_data_file(filename, Val(:por))
read_sas7bdat(filename::AbstractString) = read_data_file(filename, Val(:sas7bdat))

end #module ReadStat