xataio · kvch · Feb 18, 2025 · Jan 16, 2025 · Feb 14, 2025 · Feb 18, 2025
diff --git a/cli-definition.json b/cli-definition.json
@@ -19,6 +19,17 @@
       "subcommands": [],
       "args": []
     },
+    {
+      "name": "convert",
+      "short": "Convert SQL statements to pgroll operations from SQL",
+      "use": "convert <path to file with migrations>",
+      "example": "",
+      "flags": [],
+      "subcommands": [],
+      "args": [
+        "migration-file"
+      ]
+    },
     {
       "name": "init",
       "short": "Initialize pgroll in the target database",

diff --git a/cmd/convert.go b/cmd/convert.go
@@ -0,0 +1,44 @@
+// SPDX-License-Identifier: Apache-2.0
+
+package cmd
+
+import (
+	"fmt"
+	"io"
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+func convertCmd() *cobra.Command {
+	convertCmd := &cobra.Command{
+		Use:       "convert <path to file with migrations>",
+		Short:     "Convert SQL statements to pgroll operations from SQL",
+		Args:      cobra.MaximumNArgs(1),
+		ValidArgs: []string{"migration-file"},
+		Hidden:    true,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			reader, err := openSQLReader(args)
+			if err != nil {
+				return fmt.Errorf("open SQL migration: %w", err)
+			}
+			defer reader.Close()
+
+			_, err = scanSQLStatements(reader)
+			return err
+		},
+	}
+
+	return convertCmd
+}
+
+func openSQLReader(args []string) (io.ReadCloser, error) {
+	if len(args) == 0 {
+		return os.Stdin, nil
+	}
+	return os.Open(args[0])
+}
+
+func scanSQLStatements(reader io.Reader) ([]string, error) {
+	panic("not implemented")
+}
diff --git a/cmd/root.go b/cmd/root.go
@@ -69,6 +69,7 @@ func Prepare() *cobra.Command {
 	rootCmd.AddCommand(pullCmd())
 	rootCmd.AddCommand(latestCmd())
 	rootCmd.AddCommand(sqlCmd())
+	rootCmd.AddCommand(convertCmd())
 
 	return rootCmd
 }