sr-users

sr-users@lists.kamailio.org

11 participants
37462 discussions

[Users] BCP: rewrite every header?
by Mark Kent 21 Aug '06

21 Aug '06

I just debugged the following: A PSTN gateway we use is completely non-responsive when the INVITE has this: From: Mark Kent (desk) <sip:markkent@sip.example.com>;tag=foo Contact: Mark Kent (desk) <sip:markkent@192.0.2.216:5060> but things work OK for this: From: "Mark Kent (desk)" <sip:markkent@sip.example.com>;tag=foo Contact: "Mark Kent (desk)" <sip:markkent@192.0.2.216:5060> and also for this: From: Mark Kent <sip:markkent@sip.example.com>;tag=foo Contact: Mark Kent <sip:markkent@192.0.2.216:5060> Now, I know that the EndUser box should put quotes in there to be safe. RFC3261 says "special characters MUST be in a quoted string to be used within a parameter value." But that's not the point of this post... the point is, should I be rewriting every header? Is that standard practice? BTW, I have the same hangup with the SJphone softphone, but there I think it's because of this: From: "Mark Kent(mac)"<sip:MarkKent@sip.example.com>;tag=foo See, no space between the double-quote and the left-angle-bracket. So, should I be re-writing headers to present a single face, independent of the EndUser boxes, to external SIP gateways? Thanks, -mark P.S. FYI, the box that is not putting in the quotes is a SPA3000 running 3.1.10(GWd). A SPA942 running 4.1.10(e) puts in the quotes.

2 1

[Users] check displayname with proxy-authorizationname
by Hakan YASTI 21 Aug '06

21 Aug '06

Dear All, I want to check the "AUTHORIZATION_USERNAME" at proxy-authorization with the "DISPLAY_NAME" of the user agent.( I want them to be same ). How can I do this ? Regards, Hakan. U 2006/08/17 14:50:10.915465 10.0.0.10:9769 -> 10.0.0.15:5060 INVITE sip:DIALEDNUBER@10.0.0.15 SIP/2.0. To: <sip:DIALEDNUBER@10.0.0.15>. From: DISPLAY_NAME<sip:USERNAME@10.0.0.15>;tag=cb1e6d26. Via: SIP/2.0/UDP 10.0.0.10:9769;branch=z9hG4bK-d87543-880502875-1--d87543-;rport. Call-ID: a21d332a7f23d268. CSeq: 1 INVITE. Contact: <sip:USERNAME@10.0.0.10:9769>. Max-Forwards: 70. Allow: INVITE, ACK, CANCEL, OPTIONS, BYE, REFER, NOTIFY, MESSAGE, SUBSCRIBE, INFO. Content-Type: application/sdp. User-Agent: eyeBeam release 3004t stamp 16741. Content-Length: 229. . v=0. o=- 6672092 6672111 IN IP4 10.0.0.10. s=eyeBeam. c=IN IP4 10.0.0.10. t=0 0. m=audio 9764 RTP/AVP 18 101. a=alt:1 1 : 4F88BF12 49561D9D 10.0.0.10 9764. a=fmtp:101 0-15. a=rtpmap:101 telephone-event/8000. a=sendrecv. # U 2006/08/17 14:50:10.917409 10.0.0.15:5060 -> 10.0.0.10:9769 SIP/2.0 407 Proxy Authentication Required. To: <sip:DIALEDNUBER@10.0.0.15>;tag=bf2a561eb1268c60203a720a0640ec5a.1fcb. From: DISPLAY_NAME<sip:USERNAME@10.0.0.15>;tag=cb1e6d26. Via: SIP/2.0/UDP 10.0.0.10:9769;branch=z9hG4bK-d87543-880502875-1--d87543-;rport=9769. Call-ID: a21d332a7f23d268. CSeq: 1 INVITE. Proxy-Authenticate: Digest realm="10.0.0.15", nonce="44e4591e0c9257971b55c6113dbcbbdb18552cd3". Server: OpenSer (1.0.1 (i386/freebsd)). Content-Length: 0. Warning: 392 10.0.0.15:5060 "Noisy feedback tells: pid=1378 req_src_ip=10.0.0.10 req_src_port=9769 in_uri=sip:DIALEDNUBER@10.0.0.15 out_uri=sip:DIALEDNUBER@10.0.0.15 via_cnt==1". . # U 2006/08/17 14:50:10.919273 10.0.0.10:9769 -> 10.0.0.15:5060 ACK sip:DIALEDNUBER@10.0.0.15 SIP/2.0. To: <sip:DIALEDNUBER@10.0.0.15>;tag=bf2a561eb1268c60203a720a0640ec5a.1fcb. From: DISPLAY_NAME<sip:USERNAME@10.0.0.15>;tag=cb1e6d26. Via: SIP/2.0/UDP 10.0.0.10:9769;branch=z9hG4bK-d87543-880502875-1--d87543-;rport. Call-ID: a21d332a7f23d268. CSeq: 1 ACK. Content-Length: 0. . # U 2006/08/17 14:50:10.920445 10.0.0.10:9769 -> 10.0.0.15:5060 INVITE sip:DIALEDNUBER@10.0.0.15 SIP/2.0. To: <sip:DIALEDNUBER@10.0.0.15>. From: DISPLAY_NAME<sip:USERNAME@10.0.0.15>;tag=cb1e6d26. Via: SIP/2.0/UDP 10.0.0.10:9769;branch=z9hG4bK-d87543-460538832-1--d87543-;rport. Call-ID: a21d332a7f23d268. CSeq: 2 INVITE. Contact: <sip:USERNAME@10.0.0.10:9769>. Max-Forwards: 70. Allow: INVITE, ACK, CANCEL, OPTIONS, BYE, REFER, NOTIFY, MESSAGE, SUBSCRIBE, INFO. Content-Type: application/sdp. Proxy-Authorization: Digest username="AUTHORIZATION_USERNAME",realm="10.0.0.15",nonce="44e4591e0c9257971b55c6113dbcbbdb18552cd3",uri="sip:DIALEDNUBER@10.0.0.15",response="93036675b43665e6c94523bf841b7678",algorithm=MD5. User-Agent: eyeBeam release 3004t stamp 16741. Content-Length: 229. . v=0. o=- 6672092 6672111 IN IP4 10.0.0.10. s=eyeBeam. c=IN IP4 10.0.0.10. t=0 0. m=audio 9764 RTP/AVP 18 101. a=alt:1 1 : 4F88BF12 49561D9D 10.0.0.10 9764. a=fmtp:101 0-15. a=rtpmap:101 telephone-event/8000. a=sendrecv.

3 4

[Users] doubt in Radius and openser fro accounting...
by raviprakash sunkara 21 Aug '06

21 Aug '06

Hi Users, For Me, in Openser + radius Authorize and Acthentication is Succeed Very Good and Nice, But When some to Account, I'm little sucking here When Uac1 dials to Uac2 , ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ radacctID | AcctSessionID | AcctuniqueID | UserName | AcctStartTime | ActStopTime | calledID | callingID | ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- 1 12h34yy 2334juuw45 Uac1 13:10:00 00:00:00 Uac2 uac1 2 12h34yy ko34ji899 Uac2 13:11:11 13:11:11 Uac1 Uac2 --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- In accountting with openser + radius in should insert only one insert for every call made . But I think it insert only two records only. and AcctuniqueD should me same for each call makes then only the AcctStopTime will properly ..... in openser... -------------------- loose record----------------------------------- if(method=="BYE" || method=="CANCEL") { acc_rad_request("Stop"); unforce_rtp_proxy(); } ---------------------------- record route section------------ if( method=="INVITE" || method=="ACK") { acc_rad_request("Start"); forcr_rtp_proxy(); } plz help me in that .. sorry in my english ....... -- Thanks and Regards with cheers Sunkara Ravi Prakash (Voip Developer) Hyperion Technology Kondapur, Hi-tech city, Hyderabad. www.hyperion-tech.com +91-9985077535

2 1

[Serusers] fr_inv_timer fires some interruption?
by Ricardo Carvalho 21 Aug '06

21 Aug '06

Does modparam("tm", "fr_inv_timer", 5) fires some kind of interruption (like a failure_route) when that time (5seconds) of ringing ends? I wish that happens so my Ser be able to send calls to voicemail after ringing with no answer!! Does anybody know if that happens? Regards, Ricardo.

3 2

Re: [Users] Please help for serweb configuration in openser server
by Ferianto siregar 21 Aug '06

21 Aug '06

1 0

Re: [Users] Please help for serweb configuration in openser server
by Ferianto siregar 21 Aug '06

21 Aug '06

Dear sunkara, Thank you very much for your kind-hearted for answering my question, Thank you very much. If I can ask you more, would you mind tell me what is the name the application that I can use like "serweb" in openser server ? (the suitable "serweb" for openser server) because I am building openser server. and would you mind tell me where I can get it? Please help me, Sunkara..Please...Please... Thank you very much...Thank you... Regards, Ferianto raviprakash sunkara <sunkara.raviprakash.feb14(a)gmail.com> wrote: Hi siregar... I best Suggest is Not to user SERweb in openser. It application to SER only. not For openser , if U want to configure the serweb in openser U need to modify some changes in serweb and openser tables other things.. Perhaps try it..... Best of luck... On 8/19/06, Ferianto siregar <ferianto_voip(a)yahoo.com> wrote: Dear all, Thanks to all of you for your kind-hearted answering my question. Thank you very much. Now, I am building serweb in openser. So, the client can register to become the member of communication in my openser that I have built. 1. Can "serweb" (from iptel.org) be used in openser server for building the webserver of the openser server? Or openser has it`s own webserver except "serweb"? 2.When I build serweb (from iptel.org), I have some problems. I do hope anybody can help me and give me a suggestion. Please.. The error message that I got from client browser is Fatal error: Failed opening required 'var/www/phplib/db_mysql.inc' (include_path='.:/usr/share/pear') in /var/www/html/serweb/user_interface/prepend.php on line 23 The contain of prepend.php that shows line 23 is require($_PHPLIB["libdir"] . "db_mysql.inc"); /* Change this to match your database. */ I don`t know what is wrong. I do hope anybody can give me a suggestion. Please help me..Please. Thanks Regards, Ferianto Note: This is the contain of db_mysql.inc that I have configured <?php /* * Session Management for PHP3 * * Copyright (c) 1998-2000 NetUSE AG * Boris Erdmann, Kristian Koehntopp * * $Id: db_mysql.inc,v 1.1.1.1 2002/09/04 18:19:57 kozlik Exp $ * */ class DB_Sql { /* public: connection parameters */ var $Host = "localhost"; var $Database = "openser"; var $User = "openser"; var $Password = "openserrw"; /* public: configuration parameters */ var $Auto_Free = 0; ## Set to 1 for automatic mysql_free_result() var $Debug = 0; ## Set to 1 for debugging messages. var $Halt_On_Error = "yes"; ## "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore errror, but spit a warning) var $Seq_Table = "db_sequence"; /* public: result array and current row number */ var $Record = array(); var $Row; /* public: current error number and error text */ var $Errno = 0; var $Error = ""; /* public: this is an api revision, not a CVS revision. */ var $type = "mysql"; var $revision = "1.2"; /* private: link and query handles */ var $Link_ID = 0; var $Query_ID = 0; /* public: constructor */ function DB_Sql($query = "") { $this->query($query); } /* public: some trivial reporting */ function link_id() { return $this->Link_ID; } function query_id() { return $this->Query_ID; } /* public: connection management */ function connect($Database = "", $Host = "", $User = "", $Password = "") { /* Handle defaults */ if ("" == $Database) $Database = $this->Database; if ("" == $Host) $Host = $this->Host; if ("" == $User) $User = $this->User; if ("" == $Password) $Password = $this->Password; /* establish connection, select database */ if ( 0 == $this->Link_ID ) { $this->Link_ID=mysql_pconnect($Host, $User, $Password); if (!$this->Link_ID) { $this->halt("pconnect($Host, $User, \$Password) failed."); return 0; } if (!@mysql_select_db($Database,$this->Link_ID)) { $this->halt("cannot use database ".$Database); return 0; } } return $this->Link_ID; } /* public: discard the query result */ function free() { @mysql_free_result($this->Query_ID); $this->Query_ID = 0; } /* public: perform a query */ function query($Query_String) { /* No empty queries, please, since PHP4 chokes on them. */ if ($Query_String == "") /* The empty query string is passed on from the constructor, * when calling the class without a query, e.g. in situations * like these: '$db = new DB_Sql_Subclass;' */ return 0; if (!$this->connect()) { return 0; /* we already complained in connect() about that. */ }; # New query, discard previous result. if ($this->Query_ID) { $this->free(); } if ($this->Debug) printf("Debug: query = %s \n", $Query_String); $this->Query_ID = @mysql_query($Query_String,$this->Link_ID); $this->Row = 0; $this->Errno = mysql_errno(); $this->Error = mysql_error(); if (!$this->Query_ID) { $this->halt("Invalid SQL: ".$Query_String); } # Will return nada if it fails. That's fine. return $this->Query_ID; } /* public: walk result set */ function next_record() { if (!$this->Query_ID) { $this->halt("next_record called with no query pending."); return 0; } $this->Record = @mysql_fetch_array($this->Query_ID); $this->Row += 1; $this->Errno = mysql_errno(); $this->Error = mysql_error(); $stat = is_array($this->Record); if (!$stat && $this->Auto_Free) { $this->free(); } return $stat; } /* public: position in result set */ function seek($pos = 0) { $status = @mysql_data_seek($this->Query_ID, $pos); if ($status) $this->Row = $pos; else { $this->halt("seek($pos) failed: result has ".$this->num_rows()." rows."); /* half assed attempt to save the day, * but do not consider this documented or even * desireable behaviour. */ @mysql_data_seek($this->Query_ID, $this->num_rows()); $this->Row = $this->num_rows(); return 0; } return 1; } /* public: table locking */ function lock($table, $mode = "write") { $query = "lock tables "; if (is_array($table)) { while (list($key,$value) = each($table)) { if (!is_int($key)) { // texts key are "read", "read local", "write", "low priority write" $query .= "$value $key, "; } else { $query .= "$value $mode, "; } } $query = substr($query,0,-2); } else { $query .= "$table $mode"; } $res = $this->query($query); if (!$res) { $this->halt("lock() failed."); return 0; } return $res; } function unlock() { $res = $this->query("unlock tables"); if (!$res) { $this->halt("unlock() failed."); } return $res; } /* public: evaluate the result (size, width) */ function affected_rows() { return @mysql_affected_rows($this->Link_ID); } function num_rows() { return @mysql_num_rows($this->Query_ID); } function num_fields() { return @mysql_num_fields($this->Query_ID); } /* public: shorthand notation */ function nf() { return $this->num_rows(); } function np() { print $this->num_rows(); } function f($Name) { if (isset($this->Record[$Name])) { return $this->Record[$Name]; } } function p($Name) { if (isset($this->Record[$Name])) { print $this->Record[$Name]; } } /* public: sequence numbers */ function nextid($seq_name) { $this->connect(); if ($this->lock($this->Seq_Table)) { /* get sequence number (locked) and increment */ $q = sprintf("select nextid from %s where seq_name = '%s'", $this->Seq_Table, $seq_name); $id = @mysql_query($q, $this->Link_ID); $res = @mysql_fetch_array($id); /* No current value, make one */ if (!is_array($res)) { $currentid = 0; $q = sprintf("insert into %s values('%s', %s)", $this->Seq_Table, $seq_name, $currentid); $id = @mysql_query($q, $this->Link_ID); } else { $currentid = $res["nextid"]; } $nextid = $currentid + 1; $q = sprintf("update %s set nextid = '%s' where seq_name = '%s'", $this->Seq_Table, $nextid, $seq_name); $id = @mysql_query($q, $this->Link_ID); $this->unlock(); } else { $this->halt("cannot lock ".$this->Seq_Table." - has it been created?"); return 0; } return $nextid; } /* public: return table metadata */ function metadata($table = "", $full = false) { $count = 0; $id = 0; $res = array(); /* * Due to compatibility problems with Table we changed the behavior * of metadata(); * depending on $full, metadata returns the following values: * * - full is false (default): * $result[]: * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * * - full is true * $result[]: * ["num_fields"] number of metadata records * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * ["meta"][field name] index of field named "field name" * This last one could be used if you have a field name, but no index. * Test: if (isset($result['meta']['myfield'])) { ... */ // if no $table specified, assume that we are working with a query // result if ($table) { $this->connect(); $id = @mysql_list_fields($this->Database, $table); if (!$id) { $this->halt("Metadata query failed."); return false; } } else { $id = $this->Query_ID; if (!$id) { $this->halt("No query specified."); return false; } } $count = @mysql_num_fields($id); // made this IF due to performance (one if is faster than $count if's) if (!$full) { for ($i=0; $i<$count; $i++) { $res[$i]["table"] = @mysql_field_table ($id, $i); $res[$i]["name"] = @mysql_field_name ($id, $i); $res[$i]["type"] = @mysql_field_type ($id, $i); $res[$i]["len"] = @mysql_field_len ($id, $i); $res[$i]["flags"] = @mysql_field_flags ($id, $i); } } else { // full $res["num_fields"]= $count; for ($i=0; $i<$count; $i++) { $res[$i]["table"] = @mysql_field_table ($id, $i); $res[$i]["name"] = @mysql_field_name ($id, $i); $res[$i]["type"] = @mysql_field_type ($id, $i); $res[$i]["len"] = @mysql_field_len ($id, $i); $res[$i]["flags"] = @mysql_field_flags ($id, $i); $res["meta"][$res[$i]["name"]] = $i; } } // free the result only if we were called on a table if ($table) { @mysql_free_result($id); } return $res; } /* public: find available table names */ function table_names() { $this->connect(); $h = @mysql_query("show tables", $this->Link_ID); $i = 0; while ($info = @mysql_fetch_row($h)) { $return[$i]["table_name"] = $info[0]; $return[$i]["tablespace_name"] = $this->Database; $return[$i]["database"] = $this->Database; $i++; } @mysql_free_result($h); return $return; } /* private: error handling */ function halt($msg) { $this->Error = @mysql_error($this->Link_ID); $this->Errno = @mysql_errno($this->Link_ID); if ($this->Halt_On_Error == "no") return; $this->haltmsg($msg); if ($this->Halt_On_Error != "report") die("Session halted."); } function haltmsg($msg) { printf("</td></tr></table>Database error: %s \n", $msg); printf("MySQL Error: %s (%s) \n", $this->Errno, $this->Error); } } ?> --------------------------------- Yahoo! Messenger with Voice. Make PC-to-Phone Calls to the US (and 30+ countries) for 2ï¿½/min or less. _______________________________________________ Users mailing list Users(a)openser.org http://openser.org/cgi-bin/mailman/listinfo/users -- Thanks and Regards with cheers Sunkara Ravi Prakash Hyperion Technology Kondapur, Hi-tech city, Hyderabad. www.hyperion-tech.com +91-9985077535 --------------------------------- Talk is cheap. Use Yahoo! Messenger to make PC-to-Phone calls. Great rates starting at 1¢/min. --------------------------------- How low will we go? Check out Yahoo! Messengers low PC-to-Phone call rates.

1 0

[Users] Media proxy with getting started Document from onsip.org
by ram 21 Aug '06

21 Aug '06

Hi As per the hello world Document from Onsip.orf ( getting started) iam working with Media proxy with same config i have installed OpenSER 1.1.0 with mysql 4.3 on Cent OS, open SER runnning on Public IP. I have 3 clients Client one Pulic IP Client 2 and client 3 behind NAT ( Linksys Router) Client1 - Sipura Client 2- LeadTek Client 3 my laptop X-Lite Soft Phone the problem here is, when ever iam making call between NATed Clients, some time media proxy using some time not when ever media proxy not using then one way voice and call also not disconnecting, any solution, or suggestion Ram

1 0

[Serusers] provisioning Cisco Phone
by Mahatma Sarasvati 20 Aug '06

20 Aug '06

What solutions are available for avoiding manual editing and saving of Cisco .cnf files for individual phones while using SER or OpenSER? I've got 50-80 phones in my organization and I'm tired of manually managing the phone .cnf files I'm imagining some piece of code that auto-generates the files on command or on a schedule based on entries in the MySQL database. Maybe a column can be added to the Subscriber table or somewhere that holds the MAC address of the phone? Thanks, M

1 0

[Serusers] problem with acc module settings
by Andy Thomas 20 Aug '06

20 Aug '06

Hi, I cant start Ser 0.9.6 I get the following error when I start it up 0(4628) set_mod_param_regex: parameter <db_url> not found in module <acc> 0(4628) parse error (87,20-21): Can't set module parameter 0(4628) set_mod_param_regex: parameter <db_missed_flag> not found in module <acc> 0(4628) parse error (92,19-20): Can't set module parameter 0(4628) set_mod_param_regex: parameter <db_flag> not found in module <acc> 0(4628) parse error (93,19-20): Can't set module parameter ERROR: bad config file (3 errors) Here's my settings for the acc module - can anyone see whats wrong with it?? modparam("acc", "db_url", "mysql://ser:heslo@localhost/ser") modparam("acc", "log_level", 1) modparam("acc", "log_flag", 1) modparam("acc", "log_missed_flag", 2) modparam("acc", "log_fmt", "fimos") modparam("acc", "db_missed_flag", 2) modparam("acc", "db_flag", 1)

4 5

[Users] Please help for serweb configuration in openser server
by Ferianto siregar 19 Aug '06

19 Aug '06

Dear all, Thanks to all of you for your kind-hearted answering my question. Thank you very much. Now, I am building serweb in openser. So, the client can register to become the member of communication in my openser that I have built. 1. Can "serweb" (from iptel.org) be used in openser server for building the webserver of the openser server? Or openser has it`s own webserver except "serweb"? 2.When I build serweb (from iptel.org), I have some problems. I do hope anybody can help me and give me a suggestion. Please.. The error message that I got from client browser is Fatal error: Failed opening required 'var/www/phplib/db_mysql.inc' (include_path='.:/usr/share/pear') in /var/www/html/serweb/user_interface/prepend.php on line 23 The contain of prepend.php that shows line 23 is require($_PHPLIB["libdir"] . "db_mysql.inc"); /* Change this to match your database. */ I don`t know what is wrong. I do hope anybody can give me a suggestion. Please help me..Please. Thanks Regards, Ferianto Note: This is the contain of db_mysql.inc that I have configured <?php /* * Session Management for PHP3 * * Copyright (c) 1998-2000 NetUSE AG * Boris Erdmann, Kristian Koehntopp * * $Id: db_mysql.inc,v 1.1.1.1 2002/09/04 18:19:57 kozlik Exp $ * */ class DB_Sql { /* public: connection parameters */ var $Host = "localhost"; var $Database = "openser"; var $User = "openser"; var $Password = "openserrw"; /* public: configuration parameters */ var $Auto_Free = 0; ## Set to 1 for automatic mysql_free_result() var $Debug = 0; ## Set to 1 for debugging messages. var $Halt_On_Error = "yes"; ## "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore errror, but spit a warning) var $Seq_Table = "db_sequence"; /* public: result array and current row number */ var $Record = array(); var $Row; /* public: current error number and error text */ var $Errno = 0; var $Error = ""; /* public: this is an api revision, not a CVS revision. */ var $type = "mysql"; var $revision = "1.2"; /* private: link and query handles */ var $Link_ID = 0; var $Query_ID = 0; /* public: constructor */ function DB_Sql($query = "") { $this->query($query); } /* public: some trivial reporting */ function link_id() { return $this->Link_ID; } function query_id() { return $this->Query_ID; } /* public: connection management */ function connect($Database = "", $Host = "", $User = "", $Password = "") { /* Handle defaults */ if ("" == $Database) $Database = $this->Database; if ("" == $Host) $Host = $this->Host; if ("" == $User) $User = $this->User; if ("" == $Password) $Password = $this->Password; /* establish connection, select database */ if ( 0 == $this->Link_ID ) { $this->Link_ID=mysql_pconnect($Host, $User, $Password); if (!$this->Link_ID) { $this->halt("pconnect($Host, $User, \$Password) failed."); return 0; } if (!@mysql_select_db($Database,$this->Link_ID)) { $this->halt("cannot use database ".$Database); return 0; } } return $this->Link_ID; } /* public: discard the query result */ function free() { @mysql_free_result($this->Query_ID); $this->Query_ID = 0; } /* public: perform a query */ function query($Query_String) { /* No empty queries, please, since PHP4 chokes on them. */ if ($Query_String == "") /* The empty query string is passed on from the constructor, * when calling the class without a query, e.g. in situations * like these: '$db = new DB_Sql_Subclass;' */ return 0; if (!$this->connect()) { return 0; /* we already complained in connect() about that. */ }; # New query, discard previous result. if ($this->Query_ID) { $this->free(); } if ($this->Debug) printf("Debug: query = %s \n", $Query_String); $this->Query_ID = @mysql_query($Query_String,$this->Link_ID); $this->Row = 0; $this->Errno = mysql_errno(); $this->Error = mysql_error(); if (!$this->Query_ID) { $this->halt("Invalid SQL: ".$Query_String); } # Will return nada if it fails. That's fine. return $this->Query_ID; } /* public: walk result set */ function next_record() { if (!$this->Query_ID) { $this->halt("next_record called with no query pending."); return 0; } $this->Record = @mysql_fetch_array($this->Query_ID); $this->Row += 1; $this->Errno = mysql_errno(); $this->Error = mysql_error(); $stat = is_array($this->Record); if (!$stat && $this->Auto_Free) { $this->free(); } return $stat; } /* public: position in result set */ function seek($pos = 0) { $status = @mysql_data_seek($this->Query_ID, $pos); if ($status) $this->Row = $pos; else { $this->halt("seek($pos) failed: result has ".$this->num_rows()." rows."); /* half assed attempt to save the day, * but do not consider this documented or even * desireable behaviour. */ @mysql_data_seek($this->Query_ID, $this->num_rows()); $this->Row = $this->num_rows(); return 0; } return 1; } /* public: table locking */ function lock($table, $mode = "write") { $query = "lock tables "; if (is_array($table)) { while (list($key,$value) = each($table)) { if (!is_int($key)) { // texts key are "read", "read local", "write", "low priority write" $query .= "$value $key, "; } else { $query .= "$value $mode, "; } } $query = substr($query,0,-2); } else { $query .= "$table $mode"; } $res = $this->query($query); if (!$res) { $this->halt("lock() failed."); return 0; } return $res; } function unlock() { $res = $this->query("unlock tables"); if (!$res) { $this->halt("unlock() failed."); } return $res; } /* public: evaluate the result (size, width) */ function affected_rows() { return @mysql_affected_rows($this->Link_ID); } function num_rows() { return @mysql_num_rows($this->Query_ID); } function num_fields() { return @mysql_num_fields($this->Query_ID); } /* public: shorthand notation */ function nf() { return $this->num_rows(); } function np() { print $this->num_rows(); } function f($Name) { if (isset($this->Record[$Name])) { return $this->Record[$Name]; } } function p($Name) { if (isset($this->Record[$Name])) { print $this->Record[$Name]; } } /* public: sequence numbers */ function nextid($seq_name) { $this->connect(); if ($this->lock($this->Seq_Table)) { /* get sequence number (locked) and increment */ $q = sprintf("select nextid from %s where seq_name = '%s'", $this->Seq_Table, $seq_name); $id = @mysql_query($q, $this->Link_ID); $res = @mysql_fetch_array($id); /* No current value, make one */ if (!is_array($res)) { $currentid = 0; $q = sprintf("insert into %s values('%s', %s)", $this->Seq_Table, $seq_name, $currentid); $id = @mysql_query($q, $this->Link_ID); } else { $currentid = $res["nextid"]; } $nextid = $currentid + 1; $q = sprintf("update %s set nextid = '%s' where seq_name = '%s'", $this->Seq_Table, $nextid, $seq_name); $id = @mysql_query($q, $this->Link_ID); $this->unlock(); } else { $this->halt("cannot lock ".$this->Seq_Table." - has it been created?"); return 0; } return $nextid; } /* public: return table metadata */ function metadata($table = "", $full = false) { $count = 0; $id = 0; $res = array(); /* * Due to compatibility problems with Table we changed the behavior * of metadata(); * depending on $full, metadata returns the following values: * * - full is false (default): * $result[]: * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * * - full is true * $result[]: * ["num_fields"] number of metadata records * [0]["table"] table name * [0]["name"] field name * [0]["type"] field type * [0]["len"] field length * [0]["flags"] field flags * ["meta"][field name] index of field named "field name" * This last one could be used if you have a field name, but no index. * Test: if (isset($result['meta']['myfield'])) { ... */ // if no $table specified, assume that we are working with a query // result if ($table) { $this->connect(); $id = @mysql_list_fields($this->Database, $table); if (!$id) { $this->halt("Metadata query failed."); return false; } } else { $id = $this->Query_ID; if (!$id) { $this->halt("No query specified."); return false; } } $count = @mysql_num_fields($id); // made this IF due to performance (one if is faster than $count if's) if (!$full) { for ($i=0; $i<$count; $i++) { $res[$i]["table"] = @mysql_field_table ($id, $i); $res[$i]["name"] = @mysql_field_name ($id, $i); $res[$i]["type"] = @mysql_field_type ($id, $i); $res[$i]["len"] = @mysql_field_len ($id, $i); $res[$i]["flags"] = @mysql_field_flags ($id, $i); } } else { // full $res["num_fields"]= $count; for ($i=0; $i<$count; $i++) { $res[$i]["table"] = @mysql_field_table ($id, $i); $res[$i]["name"] = @mysql_field_name ($id, $i); $res[$i]["type"] = @mysql_field_type ($id, $i); $res[$i]["len"] = @mysql_field_len ($id, $i); $res[$i]["flags"] = @mysql_field_flags ($id, $i); $res["meta"][$res[$i]["name"]] = $i; } } // free the result only if we were called on a table if ($table) { @mysql_free_result($id); } return $res; } /* public: find available table names */ function table_names() { $this->connect(); $h = @mysql_query("show tables", $this->Link_ID); $i = 0; while ($info = @mysql_fetch_row($h)) { $return[$i]["table_name"] = $info[0]; $return[$i]["tablespace_name"] = $this->Database; $return[$i]["database"] = $this->Database; $i++; } @mysql_free_result($h); return $return; } /* private: error handling */ function halt($msg) { $this->Error = @mysql_error($this->Link_ID); $this->Errno = @mysql_errno($this->Link_ID); if ($this->Halt_On_Error == "no") return; $this->haltmsg($msg); if ($this->Halt_On_Error != "report") die("Session halted."); } function haltmsg($msg) { printf("</td></tr></table>Database error: %s \n", $msg); printf("MySQL Error: %s (%s) \n", $this->Errno, $this->Error); } } ?> --------------------------------- Yahoo! Messenger with Voice. Make PC-to-Phone Calls to the US (and 30+ countries) for 2¢/min or less.

1 0

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

2004

2003

2002

sr-users