Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for QueryContext (0.06 seconds)

  1. tests/connpool_test.go

    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.QueryContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  2. prepare_stmt.go

    			db.Stmts.Delete(query)
    		}
    	}
    	return result, err
    }
    
    func (db *PreparedStmtDB) QueryContext(ctx context.Context, query string, args ...interface{}) (rows *sql.Rows, err error) {
    	stmt, err := db.prepare(ctx, db.ConnPool, false, query)
    	if err == nil {
    		rows, err = stmt.QueryContext(ctx, args...)
    		if errors.Is(err, driver.ErrBadConn) {
    			db.Stmts.Delete(query)
    		}
    	}
    	return rows, err
    }
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  3. callbacks/row.go

    		if db.DryRun || db.Error != nil {
    			return
    		}
    
    		if isRows, ok := db.Get("rows"); ok && isRows.(bool) {
    			db.Statement.Settings.Delete("rows")
    			db.Statement.Dest, db.Error = db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    		} else {
    			db.Statement.Dest = db.Statement.ConnPool.QueryRowContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    		}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Feb 08 05:40:41 GMT 2023
    - 581 bytes
    - Click Count (0)
  4. interfaces.go

    // ConnPool db conns pool interface
    type ConnPool interface {
    	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
    	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
    	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
    	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
    }
    
    // SavePointerDialectorInterface save pointer interface
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sat Aug 19 13:33:31 GMT 2023
    - 2.2K bytes
    - Click Count (0)
  5. callbacks/delete.go

    						db.Statement.Result.Result = result
    						db.Statement.Result.RowsAffected = db.RowsAffected
    					}
    				}
    
    				return
    			}
    
    			if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    				gorm.Scan(rows, db, mode)
    
    				if db.Statement.Result != nil {
    					db.Statement.Result.RowsAffected = db.RowsAffected
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  6. callbacks/update.go

    		}
    
    		checkMissingWhereConditions(db)
    
    		if !db.DryRun && db.Error == nil {
    			if ok, mode := hasReturning(db, supportReturning); ok {
    				if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    					dest := db.Statement.Dest
    					db.Statement.Dest = db.Statement.ReflectValue.Addr().Interface()
    					gorm.Scan(rows, db, mode)
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 9.6K bytes
    - Click Count (0)
Back to Top