diff --git a/test/unit/v2/connectors/sql/__init__.py b/test/unit/v2/connectors/sql/__init__.py
new file mode 100644
index 000000000..e69de29bb
diff --git a/test/unit/v2/connectors/sql/test_sql.py b/test/unit/v2/connectors/sql/test_sql.py
new file mode 100644
index 000000000..261da340d
--- /dev/null
+++ b/test/unit/v2/connectors/sql/test_sql.py
@@ -0,0 +1,66 @@
+from pathlib import Path
+
+import pytest
+from pytest_mock import MockerFixture
+
+from unstructured_ingest.v2.interfaces.file_data import FileData, SourceIdentifiers
+from unstructured_ingest.v2.processes.connectors.sql.sql import SQLUploadStager
+
+
+@pytest.fixture
+def mock_instance() -> SQLUploadStager:
+    return SQLUploadStager()
+
+
+@pytest.mark.parametrize(
+    ("output_filename", "expected"),
+    [
+        ("filename_with_suffix.ndjson", "filename_with_suffix.ndjson"),
+        ("filename_without_suffix", "filename_without_suffix.json"),
+    ],
+)
+def test_run_output_filename_suffix(
+    mocker: MockerFixture, mock_instance: SQLUploadStager, output_filename: str, expected: str
+):
+    elements_filename = "elements.json"
+    output_dir = Path("/tmp/test/output_dir")
+
+    # Mocks
+    mock_get_data = mocker.patch(
+        "unstructured_ingest.v2.processes.connectors.sql.sql.get_data",
+        return_value=[{"key": "value"}, {"key": "value2"}],
+    )
+    mock_conform_dict = mocker.patch.object(
+        SQLUploadStager, "conform_dict", side_effect=lambda element_dict, file_data: element_dict
+    )
+    mock_conform_dataframe = mocker.patch.object(
+        SQLUploadStager, "conform_dataframe", side_effect=lambda df: df
+    )
+    mock_get_output_path = mocker.patch.object(
+        SQLUploadStager, "get_output_path", return_value=output_dir / expected
+    )
+    mock_write_output = mocker.patch.object(SQLUploadStager, "write_output")
+
+    # Act
+    result = mock_instance.run(
+        elements_filepath=Path(elements_filename),
+        file_data=FileData(
+            identifier="test",
+            connector_type="test",
+            source_identifiers=SourceIdentifiers(
+                filename=elements_filename, fullpath=elements_filename
+            ),
+        ),
+        output_dir=output_dir,
+        output_filename=output_filename,
+    )
+
+    # Assert
+    mock_get_data.assert_called_once_with(path=Path(elements_filename))
+    assert mock_conform_dict.call_count == 2
+    mock_conform_dataframe.assert_called_once()
+    mock_get_output_path.assert_called_once_with(output_filename=expected, output_dir=output_dir)
+    mock_write_output.assert_called_once_with(
+        output_path=output_dir / expected, data=[{"key": "value"}, {"key": "value2"}]
+    )
+    assert result.name == expected