@@ -157,9 +157,9 @@ const (
157157// topology.
158158//
159159// Dial will timeout after 10 seconds if a server isn't reached. The returned
160- // session will timeout operations after one minute by default if servers
161- // aren't available. To customize the timeout, see DialWithTimeout,
162- // SetSyncTimeout, and SetSocketTimeout.
160+ // session will timeout operations after one minute by default if servers aren't
161+ // available. To customize the timeout, see DialWithTimeout, SetSyncTimeout, and
162+ // SetSocketTimeout.
163163//
164164// This method is generally called just once for a given cluster. Further
165165// sessions to the same cluster are then established using the New or Copy
@@ -184,8 +184,8 @@ const (
184184// If the port number is not provided for a server, it defaults to 27017.
185185//
186186// The username and password provided in the URL will be used to authenticate
187- // into the database named after the slash at the end of the host names, or
188- // into the "admin" database if none is provided. The authentication information
187+ // into the database named after the slash at the end of the host names, or into
188+ // the "admin" database if none is provided. The authentication information
189189// will persist in sessions obtained through the New method as well.
190190//
191191// The following connection options are supported after the question mark:
@@ -235,6 +235,10 @@ const (
235235// Defines the per-server socket pool limit. Defaults to 4096.
236236// See Session.SetPoolLimit for details.
237237//
238+ // appName=<appName>
239+ //
240+ // The identifier of this client application. This parameter is used to
241+ // annotate logs / profiler output and cannot exceed 128 bytes.
238242//
239243// Relevant documentation:
240244//
@@ -279,6 +283,7 @@ func ParseURL(url string) (*DialInfo, error) {
279283 source := ""
280284 setName := ""
281285 poolLimit := 0
286+ appName := ""
282287 readPreferenceMode := Primary
283288 var readPreferenceTagSets []bson.D
284289 for _ , opt := range uinfo .options {
@@ -296,6 +301,11 @@ func ParseURL(url string) (*DialInfo, error) {
296301 if err != nil {
297302 return nil , errors .New ("bad value for maxPoolSize: " + opt .value )
298303 }
304+ case "appName" :
305+ if len (opt .value ) > 128 {
306+ return nil , errors .New ("appName too long, must be < 128 bytes: " + opt .value )
307+ }
308+ appName = opt .value
299309 case "readPreference" :
300310 switch opt .value {
301311 case "nearest" :
@@ -350,6 +360,7 @@ func ParseURL(url string) (*DialInfo, error) {
350360 Service : service ,
351361 Source : source ,
352362 PoolLimit : poolLimit ,
363+ AppName : appName ,
353364 ReadPreference : & ReadPreference {
354365 Mode : readPreferenceMode ,
355366 TagSets : readPreferenceTagSets ,
@@ -409,6 +420,9 @@ type DialInfo struct {
409420 // See Session.SetPoolLimit for details.
410421 PoolLimit int
411422
423+ // The identifier of the client application which ran the operation.
424+ AppName string
425+
412426 // ReadPreference defines the manner in which servers are chosen. See
413427 // Session.SetMode and Session.SelectServers.
414428 ReadPreference * ReadPreference
@@ -472,7 +486,7 @@ func DialWithInfo(info *DialInfo) (*Session, error) {
472486 }
473487 addrs [i ] = addr
474488 }
475- cluster := newCluster (addrs , info .Direct , info .FailFast , dialer {info .Dial , info .DialServer }, info .ReplicaSetName )
489+ cluster := newCluster (addrs , info .Direct , info .FailFast , dialer {info .Dial , info .DialServer }, info .ReplicaSetName , info . AppName )
476490 session := newSession (Eventual , cluster , info .Timeout )
477491 session .defaultdb = info .Database
478492 if session .defaultdb == "" {
@@ -652,6 +666,30 @@ func (db *Database) C(name string) *Collection {
652666 return & Collection {db , name , db .Name + "." + name }
653667}
654668
669+ // CreateView creates a view as the result of the applying the specified
670+ // aggregation pipeline to the source collection or view. Views act as
671+ // read-only collections, and are computed on demand during read operations.
672+ // MongoDB executes read operations on views as part of the underlying aggregation pipeline.
673+ //
674+ // For example:
675+ //
676+ // db := session.DB("mydb")
677+ // db.CreateView("myview", "mycoll", []bson.M{{"$match": bson.M{"c": 1}}}, nil)
678+ // view := db.C("myview")
679+ //
680+ // Relevant documentation:
681+ //
682+ // https://docs.mongodb.com/manual/core/views/
683+ // https://docs.mongodb.com/manual/reference/method/db.createView/
684+ //
685+ func (db * Database ) CreateView (view string , source string , pipeline interface {}, collation * Collation ) error {
686+ command := bson.D {{"create" , view }, {"viewOn" , source }, {"pipeline" , pipeline }}
687+ if collation != nil {
688+ command = append (command , bson.DocElem {"collation" , collation })
689+ }
690+ return db .Run (command , nil )
691+ }
692+
655693// With returns a copy of db that uses session s.
656694func (db * Database ) With (s * Session ) * Database {
657695 newdb := * db
@@ -1499,6 +1537,29 @@ func (c *Collection) DropIndexName(name string) error {
14991537 return nil
15001538}
15011539
1540+ // DropAllIndexes drops all the indexes from the c collection
1541+ func (c * Collection ) DropAllIndexes () error {
1542+ session := c .Database .Session
1543+ session .ResetIndexCache ()
1544+
1545+ session = session .Clone ()
1546+ defer session .Close ()
1547+
1548+ db := c .Database .With (session )
1549+ result := struct {
1550+ ErrMsg string
1551+ Ok bool
1552+ }{}
1553+ err := db .Run (bson.D {{"dropIndexes" , c .Name }, {"index" , "*" }}, & result )
1554+ if err != nil {
1555+ return err
1556+ }
1557+ if ! result .Ok {
1558+ return errors .New (result .ErrMsg )
1559+ }
1560+ return nil
1561+ }
1562+
15021563// nonEventual returns a clone of session and ensures it is not Eventual.
15031564// This guarantees that the server that is used for queries may be reused
15041565// afterwards when a cursor is received.
@@ -1512,19 +1573,6 @@ func (session *Session) nonEventual() *Session {
15121573
15131574// Indexes returns a list of all indexes for the collection.
15141575//
1515- // For example, this snippet would drop all available indexes:
1516- //
1517- // indexes, err := collection.Indexes()
1518- // if err != nil {
1519- // return err
1520- // }
1521- // for _, index := range indexes {
1522- // err = collection.DropIndex(index.Key...)
1523- // if err != nil {
1524- // return err
1525- // }
1526- // }
1527- //
15281576// See the EnsureIndex method for more details on indexes.
15291577func (c * Collection ) Indexes () (indexes []Index , err error ) {
15301578 cloned := c .Database .Session .nonEventual ()
0 commit comments