WIP

Author: aidanharan

lib/active_record/connection_adapters/sqlserver/schema_statements.rb

@@ -634,7 +634,9 @@ def column_definitions_sql(database, identifier)
           # puts "column_definitions_sql: identifier=#{identifier}"
           # puts "column_definitions_sql: database=#{database}"
 
-          # database = "TEMPDB" if identifier.temporary_table?
+
+
+
 
           schema_name = "schema_name()"
 
@@ -648,7 +650,10 @@ def column_definitions_sql(database, identifier)
 
           object_id_arg = identifier.schema.present? ? "CONCAT(#{schema_name},'.',#{object_name})" : object_name
 
-
+          if identifier.temporary_table?
+            database = "TEMPDB"
+            object_id_arg = "CONCAT('#{database}','..',#{object_name})"
+          end
 
           %{
             SELECT

lib/active_record/connection_adapters/sqlserver/utils.rb

@@ -85,6 +85,10 @@ def temporary_table?
             object.start_with?("#")
           end
 
+          # def temporary_database
+          #   "TEMPDB"
+          # end
+
           protected
 
           def parse_raw_name

test/cases/temporary_table_test_sqlserver.rb

@@ -0,0 +1,50 @@
+# frozen_string_literal: true
+
+require "cases/helper_sqlserver"
+
+class TemporaryTableSQLServer < ActiveRecord::TestCase
+  # setup do
+  #   @connection = ActiveRecord::Base.lease_connection
+  #   @connection.create_table(:barcodes, primary_key: "code", id: :uuid, force: true)
+  # end
+  #
+  # # teardown do
+  # #   @connection.drop_table(:barcodes, if_exists: true)
+  # # end
+  #
+  def test_insert_into_temporary_table
+    ActiveSupport::Notifications.subscribe('sql.active_record') do |_name, _start, _finish, _id, payload|
+      puts payload[:sql]
+    end
+
+
+    ActiveRecord::Base.with_connection do |conn|
+      temp_table = "#temp_users"
+      # connection.exec_query("IF OBJECT_ID('tempdb..#{temp_table}') IS NOT NULL DROP TABLE #{temp_table}")
+
+      puts "Creating table"
+      conn.exec_query("CREATE TABLE #{temp_table} (id INT IDENTITY(1,1), name NVARCHAR(100))")
+
+      puts "Selecting table"
+      result = conn.exec_query("SELECT * FROM #{temp_table}")
+      puts "Result: #{result.to_a}"
+
+      puts "Inserting into table"
+
+      # ❌ This raises "Table doesn’t exist" error
+      conn.exec_query("INSERT INTO #{temp_table} (name) VALUES ('John')")
+
+
+
+      # ✅ Workaround: Only runs if the table still exists in this session
+      # conn.exec_query("IF OBJECT_ID('tempdb..#{temp_table}') IS NOT NULL INSERT INTO #{temp_table} (name) VALUES ('John')")
+
+      # ✅ Workaround: raw_connection works without issue
+      # conn.raw_connection.execute("IF OBJECT_ID('tempdb..#{temp_table}') IS NOT NULL INSERT INTO #{temp_table} (name) VALUES ('John')")
+
+      puts "Selecting table again"
+      result = conn.exec_query("SELECT * FROM #{temp_table}")
+      puts "Result: #{result.to_a}"
+    end
+  end
+end