Function startPostgreSQL

cmd/sqlc-test-setup/main.go:404–504

()

}

func startPostgreSQL() error {
	log.Println("--- Starting PostgreSQL ---")

	dataDir := pgDataDir()
	logFile := filepath.Join(pgBaseDir(), "postgresql.log")

	// Check if already running
	if pgIsReady() {
		log.Println("postgresql is already running and accepting connections")
		return nil
	}

	// Initialize data directory if needed
	if _, err := os.Stat(filepath.Join(dataDir, "PG_VERSION")); os.IsNotExist(err) {
		log.Println("initializing postgresql data directory")
		if err := os.MkdirAll(dataDir, 0o700); err != nil {
			return fmt.Errorf("creating data directory: %w", err)
		}
		if err := run(pgBin("initdb"),
			"-D", dataDir,
			"--username=postgres",
			"--auth=trust",
		); err != nil {
			return fmt.Errorf("initdb: %w", err)
		}

		// Configure pg_hba.conf for md5 password authentication on TCP
		hbaPath := filepath.Join(dataDir, "pg_hba.conf")
		if err := configurePgHBA(hbaPath); err != nil {
			return fmt.Errorf("configuring pg_hba.conf: %w", err)
		}

		// Configure postgresql.conf to listen on localhost
		confPath := filepath.Join(dataDir, "postgresql.conf")
		if err := appendToFile(confPath,
			"\n# sqlc-test-setup configuration\n"+
				"listen_addresses = '127.0.0.1'\n"+
				"port = 5432\n",
		); err != nil {
			return fmt.Errorf("configuring postgresql.conf: %w", err)
		}
	} else {
		log.Println("postgresql data directory already initialized")
	}

	// Start PostgreSQL using pg_ctl
	log.Println("starting postgresql")
	if err := run(pgBin("pg_ctl"),
		"-D", dataDir,
		"-l", logFile,
		"-o", fmt.Sprintf("-k %s", dataDir),
		"start",
	); err != nil {
		return fmt.Errorf("pg_ctl start: %w", err)
	}

	// Wait for PostgreSQL to be ready
	log.Println("waiting for postgresql to accept connections")