mirror of
https://github.com/ent/ent.git
synced 2026-05-24 09:31:56 +03:00
a89cf1ff72
Reviewed By: alexsn Differential Revision: D17390279 fbshipit-source-id: bdf27f42d768305341bfcc6cf80fa5bde63497e9
53 lines
1.5 KiB
Go
53 lines
1.5 KiB
Go
// Copyright 2019-present Facebook Inc. All rights reserved.
|
|
// This source code is licensed under the Apache 2.0 license found
|
|
// in the LICENSE file in the root directory of this source tree.
|
|
|
|
package schema
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/facebookincubator/ent/dialect"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestWriteDriver(t *testing.T) {
|
|
b := &bytes.Buffer{}
|
|
w := WriteDriver{Driver: nopDriver{}, Writer: b}
|
|
tx, err := w.Tx(nil)
|
|
require.NoError(t, err)
|
|
err = tx.Query(nil, "SELECT `name` FROM `users`", nil, nil)
|
|
require.NoError(t, err)
|
|
err = tx.Query(nil, "SELECT `name` FROM `users`", nil, nil)
|
|
require.NoError(t, err)
|
|
err = tx.Exec(nil, "ALTER TABLE `users` ADD COLUMN `age` int", nil, nil)
|
|
require.NoError(t, err)
|
|
err = tx.Exec(nil, "ALTER TABLE `users` ADD COLUMN `NAME` varchar(100);", nil, nil)
|
|
require.NoError(t, err)
|
|
err = tx.Query(nil, "SELECT `name` FROM `users`", nil, nil)
|
|
require.NoError(t, err)
|
|
require.NoError(t, tx.Commit())
|
|
lines := strings.Split(b.String(), "\n")
|
|
require.Equal(t, "BEGIN;", lines[0])
|
|
require.Equal(t, "ALTER TABLE `users` ADD COLUMN `age` int;", lines[1])
|
|
require.Equal(t, "ALTER TABLE `users` ADD COLUMN `NAME` varchar(100);", lines[2])
|
|
require.Equal(t, "COMMIT;", lines[3])
|
|
require.Empty(t, lines[4], "file ends with blank line")
|
|
}
|
|
|
|
type nopDriver struct {
|
|
dialect.Driver
|
|
}
|
|
|
|
func (nopDriver) Exec(context.Context, string, interface{}, interface{}) error {
|
|
return nil
|
|
}
|
|
|
|
func (nopDriver) Query(context.Context, string, interface{}, interface{}) error {
|
|
return nil
|
|
}
|