本文整理汇总了Golang中github.com/flynn/flynn/Godeps/_workspace/src/github.com/jackc/pgx.Conn类的典型用法代码示例。如果您正苦于以下问题：Golang Conn类的具体用法？Golang Conn怎么用？Golang Conn使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Conn类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: ensureConnValid
// Do a simple query to ensure the connection is still usable
func ensureConnValid(t *testing.T, conn *pgx.Conn) {
var sum, rowCount int32
rows, err := conn.Query("select generate_series(1,$1)", 10)
if err != nil {
t.Fatalf("conn.Query failed: ", err)
}
defer rows.Close()
for rows.Next() {
var n int32
rows.Scan(&n)
sum += n
rowCount++
}
if rows.Err() != nil {
t.Fatalf("conn.Query failed: ", err)
}
if rowCount != 10 {
t.Error("Select called onDataRow wrong number of times")
}
if sum != 55 {
t.Error("Wrong values returned")
}
}
开发者ID:devick，项目名称:flynn，代码行数:28，代码来源:helper_test.go
示例2: waitRow
func waitRow(c *C, conn *pgx.Conn, n int) {
var res int64
err := queryAttempts.Run(func() error {
return conn.QueryRow("SELECT id FROM test WHERE id = $1", n).Scan(&res)
})
c.Assert(err, IsNil)
}
开发者ID:eldarion-gondor，项目名称:cli，代码行数:7，代码来源:postgres_test.go
示例3: mustExec
func mustExec(t testing.TB, conn *pgx.Conn, sql string, arguments ...interface{}) (commandTag pgx.CommandTag) {
var err error
if commandTag, err = conn.Exec(sql, arguments...); err != nil {
t.Fatalf("Exec unexpectedly failed with %v: %v", sql, err)
}
return
}
开发者ID:devick，项目名称:flynn，代码行数:7，代码来源:helper_test.go
示例4: testJsonInt16ArrayFailureDueToOverflow
func testJsonInt16ArrayFailureDueToOverflow(t *testing.T, conn *pgx.Conn, typename string) {
input := []int{1, 2, 234432}
var output []int16
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if _, ok := err.(*json.UnmarshalTypeError); !ok {
t.Errorf("%s: Expected *json.UnmarkalTypeError, but got %v", typename, err)
}
}
开发者ID:justintung，项目名称:flynn，代码行数:8，代码来源:values_test.go
示例5: PrepareStatements
func PrepareStatements(conn *pgx.Conn) error {
for name, sql := range preparedStatements {
if _, err := conn.Prepare(name, sql); err != nil {
return err
}
}
return nil
}
开发者ID:justintung，项目名称:flynn，代码行数:8，代码来源:que.go
示例6: unlistenAndRelease
func unlistenAndRelease(pool *pgx.ConnPool, conn *pgx.Conn, channel string) {
_, err := conn.Exec(fmt.Sprintf(sqlUnlisten, channel))
if err != nil {
conn.Close()
return
}
pool.Release(conn)
}
开发者ID:josephwinston，项目名称:flynn，代码行数:8，代码来源:data_store.go
示例7: testJsonInt16ArrayFailureDueToOverflow
func testJsonInt16ArrayFailureDueToOverflow(t *testing.T, conn *pgx.Conn, typename string) {
input := []int{1, 2, 234432}
var output []int16
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err.Error() != "can't scan into dest[0]: json: cannot unmarshal number 234432 into Go value of type int16" {
t.Errorf("%s: Expected *json.UnmarkalTypeError, but got %v", typename, err)
}
}
开发者ID:devick，项目名称:flynn，代码行数:8，代码来源:values_test.go
示例8: mustPrepare
func mustPrepare(t testing.TB, conn *pgx.Conn, name, sql string) *pgx.PreparedStatement {
ps, err := conn.Prepare(name, sql)
if err != nil {
t.Fatalf("Could not prepare %v: %v", name, err)
}
return ps
}
开发者ID:josephwinston，项目名称:flynn，代码行数:8，代码来源:helper_test.go
示例9: benchmarkSelectWithLog
func benchmarkSelectWithLog(b *testing.B, conn *pgx.Conn) {
_, err := conn.Prepare("test", "select 1::int4, 'johnsmith', '[email protected]', 'John Smith', 'male', '1970-01-01'::date, '2015-01-01 00:00:00'::timestamptz")
if err != nil {
b.Fatal(err)
}
b.ResetTimer()
for i := 0; i < b.N; i++ {
var record struct {
id int32
userName string
email string
name string
sex string
birthDate time.Time
lastLoginTime time.Time
}
err = conn.QueryRow("test").Scan(
&record.id,
&record.userName,
&record.email,
&record.name,
&record.sex,
&record.birthDate,
&record.lastLoginTime,
)
if err != nil {
b.Fatal(err)
}
// These checks both ensure that the correct data was returned
// and provide a benchmark of accessing the returned values.
if record.id != 1 {
b.Fatalf("bad value for id: %v", record.id)
}
if record.userName != "johnsmith" {
b.Fatalf("bad value for userName: %v", record.userName)
}
if record.email != "[email protected]" {
b.Fatalf("bad value for email: %v", record.email)
}
if record.name != "John Smith" {
b.Fatalf("bad value for name: %v", record.name)
}
if record.sex != "male" {
b.Fatalf("bad value for sex: %v", record.sex)
}
if record.birthDate != time.Date(1970, 1, 1, 0, 0, 0, 0, time.Local) {
b.Fatalf("bad value for birthDate: %v", record.birthDate)
}
if record.lastLoginTime != time.Date(2015, 1, 1, 0, 0, 0, 0, time.Local) {
b.Fatalf("bad value for lastLoginTime: %v", record.lastLoginTime)
}
}
}
开发者ID:devick，项目名称:flynn，代码行数:56，代码来源:bench_test.go
示例10: testJsonStringArray
func testJsonStringArray(t *testing.T, conn *pgx.Conn, typename string) {
input := []string{"foo", "bar", "baz"}
var output []string
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err != nil {
t.Errorf("%s: QueryRow Scan failed: %v", typename, err)
}
if !reflect.DeepEqual(input, output) {
t.Errorf("%s: Did not transcode []string successfully: %v is not %v", typename, input, output)
}
}
开发者ID:devick，项目名称:flynn，代码行数:12，代码来源:values_test.go
示例11: testJsonInt64Array
func testJsonInt64Array(t *testing.T, conn *pgx.Conn, typename string) {
input := []int64{1, 2, 234432}
var output []int64
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err != nil {
t.Errorf("%s: QueryRow Scan failed: %v", typename, err)
}
if !reflect.DeepEqual(input, output) {
t.Errorf("%s: Did not transcode []int64 successfully: %v is not %v", typename, input, output)
}
}
开发者ID:devick，项目名称:flynn，代码行数:12，代码来源:values_test.go
示例12: waitReadWrite
func waitReadWrite(c *C, conn *pgx.Conn) {
var readOnly string
err := queryAttempts.Run(func() error {
if err := conn.QueryRow("SHOW default_transaction_read_only").Scan(&readOnly); err != nil {
return err
}
if readOnly == "off" {
return nil
}
return fmt.Errorf("transaction readonly is %q", readOnly)
})
c.Assert(err, IsNil)
}
开发者ID:eldarion-gondor，项目名称:cli，代码行数:13，代码来源:postgres_test.go
示例13: testJsonSingleLevelStringMap
func testJsonSingleLevelStringMap(t *testing.T, conn *pgx.Conn, typename string) {
input := map[string]string{"key": "value"}
var output map[string]string
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err != nil {
t.Errorf("%s: QueryRow Scan failed: %v", typename, err)
return
}
if !reflect.DeepEqual(input, output) {
t.Errorf("%s: Did not transcode map[string]string successfully: %v is not %v", typename, input, output)
return
}
}
开发者ID:devick，项目名称:flynn，代码行数:14，代码来源:values_test.go
示例14: waitRecovered
func waitRecovered(c *C, conn *pgx.Conn) {
var recovery bool
err := queryAttempts.Run(func() error {
err := conn.QueryRow("SELECT pg_is_in_recovery()").Scan(&recovery)
if err != nil {
return err
}
if recovery {
return fmt.Errorf("in recovery")
}
return nil
})
c.Assert(err, IsNil)
}
开发者ID:eldarion-gondor，项目名称:cli，代码行数:14，代码来源:postgres_test.go
示例15: testJsonNestedMap
func testJsonNestedMap(t *testing.T, conn *pgx.Conn, typename string) {
input := map[string]interface{}{
"name": "Uncanny",
"stats": map[string]interface{}{"hp": float64(107), "maxhp": float64(150)},
"inventory": []interface{}{"phone", "key"},
}
var output map[string]interface{}
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err != nil {
t.Errorf("%s: QueryRow Scan failed: %v", typename, err)
return
}
if !reflect.DeepEqual(input, output) {
t.Errorf("%s: Did not transcode map[string]interface{} successfully: %v is not %v", typename, input, output)
return
}
}
开发者ID:devick，项目名称:flynn，代码行数:18，代码来源:values_test.go
示例16: afterConnect
// afterConnect creates the prepared statements that this application uses
func afterConnect(conn *pgx.Conn) (err error) {
_, err = conn.Prepare("getUrl", `
select url from shortened_urls where id=$1
`)
if err != nil {
return
}
_, err = conn.Prepare("deleteUrl", `
delete from shortened_urls where id=$1
`)
if err != nil {
return
}
// There technically is a small race condition in doing an upsert with a CTE
// where one of two simultaneous requests to the shortened URL would fail
// with a unique index violation. As the point of this demo is pgx usage and
// not how to perfectly upsert in PostgreSQL it is deemed acceptable.
_, err = conn.Prepare("putUrl", `
with upsert as (
update shortened_urls
set url=$2
where id=$1
returning *
)
insert into shortened_urls(id, url)
select $1, $2 where not exists(select 1 from upsert)
`)
return
}
开发者ID:devick，项目名称:flynn，代码行数:32，代码来源:main.go
示例17: testJsonStruct
func testJsonStruct(t *testing.T, conn *pgx.Conn, typename string) {
type person struct {
Name string `json:"name"`
Age int `json:"age"`
}
input := person{
Name: "John",
Age: 42,
}
var output person
err := conn.QueryRow("select $1::"+typename, input).Scan(&output)
if err != nil {
t.Errorf("%s: QueryRow Scan failed: %v", typename, err)
}
if !reflect.DeepEqual(input, output) {
t.Errorf("%s: Did not transcode struct successfully: %v is not %v", typename, input, output)
}
}
开发者ID:devick，项目名称:flynn，代码行数:22，代码来源:values_test.go
示例18: closeConn
func closeConn(t testing.TB, conn *pgx.Conn) {
err := conn.Close()
if err != nil {
t.Fatalf("conn.Close unexpectedly failed: %v", err)
}
}
开发者ID:devick，项目名称:flynn，代码行数:6，代码来源:helper_test.go
示例19: assertDownstream
func assertDownstream(c *C, conn *pgx.Conn, n int) {
var res string
err := conn.QueryRow("SELECT client_addr FROM pg_stat_replication WHERE application_name = $1", fmt.Sprintf("node%d", n)).Scan(&res)
c.Assert(err, IsNil)
}
开发者ID:eldarion-gondor，项目名称:cli，代码行数:5，代码来源:postgres_test.go
示例20: assertRecovery
func assertRecovery(c *C, conn *pgx.Conn) {
var recovery bool
err := conn.QueryRow("SELECT pg_is_in_recovery()").Scan(&recovery)
c.Assert(err, IsNil)
c.Assert(recovery, Equals, true)
}
开发者ID:eldarion-gondor，项目名称:cli，代码行数:6，代码来源:postgres_test.go
注：本文中的github.com/flynn/flynn/Godeps/_workspace/src/github.com/jackc/pgx.Conn类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论