Fix compilation and linking issues

- Resolved linking errors encountered during the build process.
- Adjusted relevant code to ensure successful compilation.

Author: wudidapaopao

.rubocop.yml

@@ -2,6 +2,8 @@ AllCops:
   Exclude:
     - 'vendor/**/*'
     - 'spec/**/*' 
+    - 'tmp/**/*'
+    - 'ext/**/extconf.rb'
 
   NewCops: enable
 

chdb.gemspec

@@ -54,5 +54,7 @@ Gem::Specification.new do |s|
 
   s.rdoc_options = ['--main', 'README.md']
 
+  s.add_dependency 'csv', '~> 3.1'
+
   s.extensions << 'ext/chdb/extconf.rb'
 end

ext/chdb/chdb.c

@@ -3,11 +3,9 @@
 #include "chdb.h"
 #include "constants.h"
 #include "connection.h"
+#include "exception.h"
 #include "local_result.h"
 
-VALUE cChDBError;
-VALUE cLocalResult;
-
 void init_chdb_constants()
 {
     VALUE mChDB = rb_define_module("ChDB");
@@ -19,47 +17,12 @@ void init_chdb_constants()
     rb_define_const(mmChDBOpen, "CREATE", INT2FIX(CHDB_OPEN_CREATE));
 }
 
-void init_exception()
-{
-    VALUE mChDB = rb_define_module("ChDB");
-    if (rb_const_defined(mChDB, rb_intern("Exception")))
-    {
-        cChDBError = rb_const_get(mChDB, rb_intern("Exception"));
-    }
-    else
-    {
-        cChDBError = rb_define_class_under(mChDB, "Exception", rb_eStandardError);
-    }
-}
-
-void init_local_result()
-{
-    VALUE mChDB = rb_define_module("ChDB");
-    cLocalResult = rb_define_class_under(mChDB, "LocalResult", rb_cObject);
-    rb_define_alloc_func(cLocalResult, local_result_alloc);
-    rb_define_method(cLocalResult, "buf", local_result_buf, 0);
-    rb_define_method(cLocalResult, "elapsed", local_result_elapsed, 0);
-    rb_define_method(cLocalResult, "rows_read", local_result_rows_read, 0);
-    rb_define_method(cLocalResult, "bytes_read", local_result_bytes_read, 0);
-}
-
-void init_connection()
-{
-    VALUE mChDB = rb_define_module("ChDB");
-    VALUE cConnection = rb_define_class_under(mChDB, "Connection", rb_cObject);
-    rb_define_alloc_func(cConnection, connection_alloc);
-    rb_define_method(cConnection, "initialize", connection_initialize, 2);
-    rb_define_method(cConnection, "query", connection_query, 2);
-    rb_define_method(cConnection, "close", connection_close, 0);
-}
-
-
-void Init_chdb(void)
+void Init_chdb_native()
 {
     DEBUG_PRINT("Initializing chdb extension");
 
-    init_chdb_constants();
     init_exception();
+    init_chdb_constants();
     init_local_result();
     init_connection();
 

ext/chdb/chdb.h

@@ -1,5 +1,20 @@
 #include "connection.h"
 
+#include "constants.h"
+#include "exception.h"
+#include "include/chdb.h"
+#include "local_result.h"
+
+void init_connection()
+{
+    VALUE mChDB = rb_define_module("ChDB");
+    VALUE cConnection = rb_define_class_under(mChDB, "Connection", rb_cObject);
+    rb_define_alloc_func(cConnection, connection_alloc);
+    rb_define_method(cConnection, "initialize", connection_initialize, 2);
+    rb_define_method(cConnection, "query", connection_query, 2);
+    rb_define_method(cConnection, "close", connection_close, 0);
+}
+
 VALUE connection_alloc(VALUE klass)
 {
     Connection *conn = ALLOC(Connection);

ext/chdb/connection.c

@@ -10,6 +10,8 @@ typedef struct
 
 extern const rb_data_type_t ConnectionType;
 
+void init_connection();
+
 VALUE connection_alloc(VALUE klass);
 
 VALUE connection_initialize(VALUE self, VALUE argc, VALUE argv);
@@ -18,4 +20,4 @@ VALUE connection_query(VALUE self, VALUE query, VALUE format);
 
 VALUE connection_close(VALUE self);
 
-#endif
+#endif

ext/chdb/connection.h

@@ -0,0 +1,16 @@
+#include "exception.h"
+
+VALUE cChDBError;
+
+void init_exception()
+{
+    VALUE mChDB = rb_define_module("ChDB");
+    if (rb_const_defined(mChDB, rb_intern("Exception")))
+    {
+        cChDBError = rb_const_get(mChDB, rb_intern("Exception"));
+    }
+    else
+    {
+        cChDBError = rb_define_class_under(mChDB, "Exception", rb_eStandardError);
+    }
+}

ext/chdb/exception.c

@@ -0,0 +1,10 @@
+#ifndef CHDB_EXCEPTION_H
+#define CHDB_EXCEPTION_H
+
+#include <ruby.h>
+
+extern VALUE cChDBError;
+
+void init_exception();
+
+#endif

ext/chdb/exception.h

@@ -3,13 +3,12 @@
 require 'fileutils'
 require 'mkmf'
 require 'yaml'
+require 'open-uri'
 
 module ChDB
   module ExtConf
     class << self
       def configure
-        configure_cross_compiler
-
         download_and_extract
 
         configure_extension
@@ -33,7 +32,12 @@ def configure_extension
         lib_path = File.expand_path('ext/chdb/lib', package_root_dir)
         append_ldflags("-L#{lib_path}")
 
-        append_ldflags("-Wl,-rpath,'$$ORIGIN/../lib'")
+        target_platform = determine_target_platform
+        if target_platform.include?('darwin')
+          append_ldflags('-Wl,-rpath,@loader_path/../lib')
+        else
+          append_ldflags("-Wl,-rpath,'$$ORIGIN/../lib'")
+        end
 
         abort_could_not_find('chdb.h') unless find_header('chdb.h', include_path)
 
@@ -53,9 +57,10 @@ def abort_could_not_find(missing)
       def download_and_extract
         target_platform = determine_target_platform
         version = fetch_chdb_version
-        download_dir = setup_download_directory(target_platform, version)
+        download_dir = determine_download_directory(target_platform, version)
 
         unless Dir.exist?(download_dir)
+          FileUtils.mkdir_p(download_dir)
           file_name = get_file_name(target_platform)
           url = build_download_url(version, file_name)
           download_tarball(url, download_dir, file_name)
@@ -68,18 +73,25 @@ def download_and_extract
       private
 
       def determine_target_platform
-        ENV['TARGET'] || host_platform
+        return ENV['TARGET'].strip if ENV['TARGET'] && !ENV['TARGET'].strip.empty?
+
+        case RUBY_PLATFORM
+        when /aarch64-linux/ then 'aarch64-linux-gnu'
+        when /x86_64-linux/  then 'x86_64-linux-gnu'
+        when /arm64-darwin/  then 'arm64-darwin'
+        when /x86_64-darwin/ then 'x86_64-darwin'
+        else
+          'unknown-platform'
+        end
       end
 
       def fetch_chdb_version
         dependencies = YAML.load_file(File.join(package_root_dir, 'dependencies.yml'), symbolize_names: true)
         dependencies[:chdb][:version]
       end
 
-      def setup_download_directory(target_platform, version)
-        download_dir = File.join(package_root_dir, 'deps', version, target_platform)
-        FileUtils.mkdir_p(download_dir)
-        download_dir
+      def determine_download_directory(target_platform, version)
+        File.join(package_root_dir, 'deps', version, target_platform)
       end
 
       def get_file_name(target_platform)
@@ -99,6 +111,7 @@ def build_download_url(version, file_name)
       def download_tarball(url, download_dir, file_name)
         tarball = File.join(download_dir, file_name)
         puts "Downloading chdb library for #{determine_target_platform}..."
+
         URI.open(url) do |remote| # rubocop:disable Security/Open
           IO.copy_stream(remote, tarball)
         end
@@ -111,16 +124,24 @@ def extract_tarball(download_dir, file_name)
 
       def copy_files(download_dir, _version)
         ext_chdb_path = File.join(package_root_dir, 'ext/chdb')
-        [%w[include *.h], %w[lib *.so], %w[lib *.dylib]].each do |(src_dir, pattern)|
+        [%w[*.h], %w[*.so], %w[*.dylib]].each do |(glob_pattern)|
+          src_dir, pattern = File.split(glob_pattern)
+
+          dest_subdir = case pattern
+                        when '*.h' then 'include'
+                        else 'lib'
+                        end
           src = File.join(download_dir, src_dir, pattern)
-          dest = File.join(ext_chdb_path, src_dir)
+          dest = File.join(ext_chdb_path, dest_subdir)
           FileUtils.mkdir_p(dest)
           FileUtils.cp_r(Dir.glob(src), dest, remove_destination: true)
-        end
-      end
 
-      def host_platform
-        RbConfig::CONFIG['host_os'].downcase
+          target_platform = determine_target_platform
+          if target_platform.include?('darwin') && (pattern == '*.so')
+            system("install_name_tool -id '@rpath/libchdb.so' #{File.join(dest, 'libchdb.so')}")
+            system("codesign -f -s - #{File.join(dest, 'libchdb.so')}")
+          end
+        end
       end
 
       def package_root_dir