@@ -64,11 +64,9 @@ public Connector(DatabaseSettings settings)
64
64
/// <param name="userId">The user id</param>
65
65
/// <param name="password">The password</param>
66
66
/// <param name="port">The port (optional)</param>
67
- public Connector ( string server , string database , string userId , string password , uint port = 3306 ) : this (
68
- new DatabaseSettings ( server , database , userId , password . ToSecureString ( ) , port ) )
69
- {
70
-
71
- }
67
+ /// <param name="connectionTimeout">The connection timeout (optional, 15 = default value)</param>
68
+ public Connector ( string server , string database , string userId , string password , uint port = 3306 , uint connectionTimeout = 15 ) : this (
69
+ new DatabaseSettings ( server , database , userId , password . ToSecureString ( ) , port , connectionTimeout ) ) { }
72
70
73
71
/// <summary>
74
72
/// Creates a new instance of the <see cref="Connector"/>
@@ -78,11 +76,9 @@ public Connector(string server, string database, string userId, string password,
78
76
/// <param name="userId">The user id</param>
79
77
/// <param name="password">The password</param>
80
78
/// <param name="port">The port (optional)</param>
81
- public Connector ( string server , string database , string userId , SecureString password , uint port = 3306 ) : this (
82
- new DatabaseSettings ( server , database , userId , password , port ) )
83
- {
84
-
85
- }
79
+ /// <param name="connectionTimeout">The connection timeout (optional, 15 = default value)</param>
80
+ public Connector ( string server , string database , string userId , SecureString password , uint port = 3306 , uint connectionTimeout = 15 ) : this (
81
+ new DatabaseSettings ( server , database , userId , password , port , connectionTimeout ) ) { }
86
82
87
83
/// <summary>
88
84
/// Creates a new instance of the <see cref="Connector"/>
@@ -98,14 +94,21 @@ public Connector(SecureString connectionString)
98
94
/// </summary>
99
95
private void CreateConnectionString ( )
100
96
{
101
- _connectionString = new MySqlConnectionStringBuilder
97
+ var conString = new MySqlConnectionStringBuilder
102
98
{
103
99
Server = _settings . Server ,
104
100
Database = _settings . Database ,
105
101
UserID = _settings . UserId ,
106
102
Password = _settings . Password . ToInsecureString ( ) ,
107
103
Port = _settings . Port
108
- } . ConnectionString . ToSecureString ( ) ;
104
+ } ;
105
+
106
+ if ( _settings . ConnectionTimeout > 0 )
107
+ conString . ConnectionTimeout = _settings . ConnectionTimeout ;
108
+ else
109
+ _settings . ConnectionTimeout = conString . ConnectionTimeout ;
110
+
111
+ _connectionString = conString . ConnectionString . ToSecureString ( ) ;
109
112
}
110
113
111
114
/// <summary>
@@ -145,31 +148,7 @@ public void SwitchDatabase(string database)
145
148
/// <returns>The connection string info</returns>
146
149
public string ConnectionStringInfo ( ConnectionInfoType type )
147
150
{
148
- var server = $ "Server: { _settings . Server } ";
149
- var database = $ "Database: { _settings . Database } ";
150
- var user = $ "User: { _settings . UserId } ";
151
- var port = $ "Port: { _settings . Port } ";
152
-
153
- return ( int ) type switch
154
- {
155
- 0 => "" ,
156
- 1 => server ,
157
- 2 => database ,
158
- 3 => $ "{ server } ; { database } ",
159
- 4 => user ,
160
- 5 => $ "{ server } ; { user } ",
161
- 6 => $ "{ database } ; { user } ",
162
- 7 => $ "{ server } ; { database } ; { user } ",
163
- 8 => port ,
164
- 9 => $ "{ server } ; { port } ",
165
- 10 => $ "{ database } ; { port } ",
166
- 11 => $ "{ server } ; { database } ; { port } ",
167
- 12 => $ "{ user } ; { port } ",
168
- 13 => $ "{ server } ; { user } ; { port } ",
169
- 14 => $ "{ database } ; { user } ; { port } ",
170
- 15 => $ "{ server } ; { database } ; { user } ; { port } ",
171
- _ => ""
172
- } ;
151
+ return Helper . GetConnectionInfo ( type , _settings ) ;
173
152
}
174
153
175
154
/// <summary>
0 commit comments