免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 数据库技术 › Oracle › [技巧]tnscmd 工具C語言版本
最近访问板块 发新帖
查看: 6648 | 回复: 4
打印 上一主题 下一主题

[技巧]tnscmd 工具C語言版本 [复制链接]

gangjh

求职 : 数据库管理员
论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2007-11-20 09:13 |只看该作者 |倒序浏览
tnscmd.pl 是一個強大的遠端管理Oracle Listener的工具.
由perl語言實現.
可以查看監聽器狀況,版本,列舉服務,停止監聽等.
查看Oracle 10g時有出現tns版本不符狀況.
TNS COMMAND需要新增一項(VERSION=169869568))
仿照tnscmd的思想用C語言重新實現了一遍.

程序還不是怎麼完善,但基本可用.
感興趣的朋友可以玩玩

歡迎大家一起幫忙來改進,完善它.



11/24日已稍作更新.
為方便本機沒有gcc的朋友,下載檔中新增一個編譯好的tnscmd.exe




在linux和windows平台下可用gcc編議

compile

  2. win32:
  3. gcc -Wall  -o tnscmd   tnscmd.c -lwsock32
  4. Linux;
  5. gcc -Wall  -o tnscmd   tnscmd.c
复制代码


使用
如果監聽器有設置可令才需要 -p password

  2. $tnscmd  status   -h oraclehost
  3. $tnscmd -h oraclehost
  4. $tnscmd status -h oraclehost -p password
  5. 停止監聽
  6. $tnscmd stop -h oraclehost
复制代码




部份代碼是從我常用的庫中剝出來的,
圖方便就直接放在 tnscmd.h中了

tnscmd.h

  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <ctype.h>

  6. #ifdef _WIN32
  7.         #include <winerror.h>
  8.         #include <wininet.h>
  9.         #include <winsock.h>
  10.         #include <stdint.h>

  12.         #include <winsock2.h>
  13.         #define sockstart(name)  \
  14.                 do {\
  15.                         WSADATA name;  \
  16.                         if (WSAStartup(MAKEWORD(1,1) ,&name))  \
  17.                                 perror("sockstart") ;  \
  18.                 } while(0)

  20.         #define sockend()  WSACleanup()

  22. #else
  23.         #include <unistd.h>
  24.         #include <sys/socket.h>
  25.         #include <sys/types.h>
  26.         #include <arpa/inet.h>
  27.         #include <netinet/in.h>
  28.         #include <netdb.h>
  29.         #define sockstart(name)
  30.         #define sockend()

  32.         #ifndef  closesocket
  33.                 #define closesocket  close
  34.         #endif
  35. #endif




  40. /*
  41. @tcp_connect:

  43. @ return socket   
  44. */

  46. int  tcp_connect(const  char *hostname,  uint16_t   port)
  47. {
  48.         int  sockfd ;
  49.         struct hostent *hostent ;

  51.         struct sockaddr_in client_addr;



  55.         hostent = gethostbyname(hostname);

  57.         if(NULL == hostent) {
  58.                  return  -1 ;
  59.         }


  62.         if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){
  63.                 perror("sockfd ");
  64.                 return (-2);
  65.         }
  66.         client_addr.sin_family=AF_INET;
  67.         client_addr.sin_port=htons( port );


  70.         memcpy(&client_addr.sin_addr, hostent->h_addr_list[0], sizeof(client_addr.sin_addr));


  73.         memset(&(client_addr.sin_zero),0,8);
  74.         if (connect(sockfd, (struct sockaddr *)&client_addr, sizeof(struct sockaddr)) == -1) {
  75.                 perror("Connec Error");
  76.                 return -3 ;
  77.         }


  80.         return (sockfd );
  81. }

  83. void int2hex(char *dest, int val, int size)
  84. {
  85.          int i ;
  86.          unsigned int x=val;
  87.          char *dic="0123456789ABCDEF" ;
  88.          for (i=0; i<size; i++){
  89.                dest[size-1-i]= dic[ x & 0x0f] ;
  90.                x = x >>4 ;
  91.          }

  93. }


  96. void sprt_hex(char *buf, char ch, int idx)
  97. {
  98.          char *p ;

  100.          p=buf +idx *3 ;
  101.          if (idx>7) {
  102.                  p+=1 ;
  103.          }

  105.          int2hex(p,ch, 2);
  106.          p[2] =' ';


  109.          if (isprint(ch)) {
  110.                  buf[50+idx]= ch ;
  111.          } else {
  112.                  buf[50+idx]= '.' ;
  113.          }
  114.   
  115.   
  116. }

  118. #define  LSIZE 80

  120. /*
  121. * hex_dump: print ptr in hex mode
  122. *           16 byte/line
  123. *   
  124. */

  126. void hex_dump( char *ptr, int size, int offset)
  127. {

  129.          char buf[LSIZE] ;
  130.          

  132.          
  133.          int x;
  134.          char *p=ptr ;
  135.          char *lim = p+ size ;



  139.          while (p <lim) {
  140.                  memset(buf,' ', LSIZE) ;
  141.                  x =p-ptr ;
  142.                  x+= offset;
  143.                  int2hex(buf, x , 6);

  145.                  for (x=0;  x<16 && p<lim;   x++,p++)
  146.                         sprt_hex(&buf[8], *p,  x);

  148.                  x =58;
  149.                  buf[x-1] ='|';
  150.                  buf[x+16] ='|' ;
  151.                  buf[x+16+1] ='\0';
  152.                  fprintf(stderr, "%s\n",buf);

  154.          }
  155. }




  160. size_t dump_char(const void *ptr, size_t size, size_t nmemb,
  161.               FILE *stream)
  162. {
  163.   /*
  164.             return fwrite(ptr,size,  nmemb, stream);
  165.   */
  166.            char *p=(char *)ptr ;
  167.          char *lim = p + size * nmemb  ;
  168.          char ch;
  169.          

  171.          for (;p<lim; p++) {
  172.                  ch = *p ;
  173.                  if  (isprint(ch) || ch =='\n' || ch=='\r' ) {
  174.                          putc(ch, stream);
  175.                  }else {
  176.                          fputc('.', stream);

  178.                  }
  179.                  
  180.          }

  182.          return 0;
  183. }






  190. size_t dump_char_parenify(const void *ptr, size_t size, size_t nmemb,
  191.               FILE *stream)
  192. {

  194.            char *p=(char *)ptr ;
  195.          char *lim = p + size * nmemb  ;
  196.          char ch;
  197.          int indent =0 ;
  198.          int o_indent = 0;
  199.          int i ;
  200.          for (;p<lim; p++) {
  201.                  ch = *p ;
  202.                  if (ch =='(') indent++;
  203.                  if (ch ==')') indent--;
  204.                  if (indent != o_indent) {
  205.                          if (p[1]  != '('   ){
  206.                                  fputc('\n', stream);
  207.                          }

  209.                          for (i=0; i< indent; i++) {
  210.                                  fprintf(stream, "  ");
  211.                          }
  212.                          o_indent = indent ;
  213.                  }
  214.                  
  215.                  //putc(ch,stream);
  216.                  
  217.                  if  (isprint(ch) || ch =='\n' || ch=='\r' ) {
  218.                          putc(ch, stream);
  219.                  }else {
  220.                          fputc(' ', stream);
  221.                  }
  222.                  
  223.                  
  224.          }
  225.          return 0;
  226. }





  232. void  usage();


复制代码


tnscmd.c

  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5. #include <unistd.h>

  7. #include "tnscmd.h"
  8. #define BSIZE  10240


  11. /*Oracle 8.1.7 head */  
  12. char  head_pack[]  = { 0,    0   , 0x00, 0x00, 0x01, 0x00, 0x00, 0x00,\
  13.                        0x01, 0x36, 0x01, 0x2c, 0x00, 0x00, 0x08, 0x00,\
  14.                        0x7f, 0xff, 0x7f, 0x08, 0x00, 0x00, 0x00, 0x01,\
  15.                        0,    0 ,   0x00, 0x3a, 0x00, 0x00, 0x00, 0x00,\
  16.                        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,\
  17.                        0x00, 0x00, 0x00, 0x00, 0x34, 0xe6, 0x00, 0x00,\
  18.                        0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,\
  19.                        0x00, 0x00 };




  24. /*Oracle 10.0.1  head */  
  25. char head_pack1[] ={ 0,   0   ,0x00,0x00,0x01,0x00,0x00, 0x00,
  26.                      0x01,0x39,0x01,0x2c,0x00,0x00,0x08, 0x00,
  27.                      0x7f,0xff,0x7f,0x08,0x00,0x00,0x01, 0x00,
  28.                      0,   0,   0x00,0x3a,0x00,0x00,0x00, 0x00,
  29.                      0x00,0x00,0x00,0x00,0x00,0x00,0x00, 0x00,
  30.                      0x00,0x00,0x00,0x00,0x00,0x00,0x00, 0x00,
  31.                      0x00,0x00,0x00,0x00,0x00,0x00,0x00, 0x00,
  32.                      0x00,0x00} ;



  36. size_t (* write_func)(const void *ptr, size_t size, size_t nmemb,   FILE *stream) = dump_char  ;
  37. int debug_mode = 0;





  43. int build_packet(char *dest, char *cmd)
  44. {
  45.          int cmd_len = strlen(cmd) ;
  46.          int packetlen = sizeof(head_pack)  + cmd_len;

  48.          memcpy(dest, head_pack,  sizeof(head_pack));
  49.          

  51.          dest[0] =(char) packetlen  >> 8;
  52.          dest[1] =(char) packetlen & 0xff;

  54.          


  57.          dest[24] = (char) cmd_len >>8 ;
  58.          dest[25] = (char) cmd_len & 0xff ;
  59.          memcpy(&dest[sizeof(head_pack)], cmd, strlen(cmd));
  60.          
  61.          return  sizeof(head_pack)  + strlen(cmd) ;
  62. }


  65. int getpacklen(unsigned char *p)
  66. {

  68.          unsigned char c0,c1 ;
  69.          c0 =p[0] ;
  70.          c1 =p[1] ;
  71.          return c0 *256 + c1 ;
  72. }


  75. int ora_recv(unsigned int sock, void *buf, unsigned int *packlen)
  76. {

  78.          int rlen =0;

  80.          rlen = recv(sock,buf, BSIZE , 0);  
  81.          if (rlen <=0) {
  82.                  *packlen = 0;
  83.                  return 0;
  84.          }
  85.          *packlen  = getpacklen(buf)  ;

  87.          if (debug_mode ==1) {
  88.                  fprintf(stdout, "recv:%d  packlen:%d\n",rlen , *packlen );
  89.                  hex_dump(buf, rlen, 0);
  90.          }
  91.          

  93.          return rlen ;
  94. }

  96. /*
  97. @tns_cmd : send tns command && recv message from oracle listener

  99. */

  101. int tns_cmd(int sock,char *cmd,char *pass)
  102. {
  103.          char buf[BSIZE] ;


  106.          char command[1024];
  107.          unsigned int packlen =0;

  109.          ssize_t rlen ,slen;
  110.          


  113.          if (pass ==NULL)
  114.                  sprintf(command,"(CONNECT_DATA=(COMMAND=%s)(VERSION=169869568))",cmd);
  115.          else
  116.                  sprintf(command,"(CONNECT_DATA=(COMMAND=%s)(PASSWORD=%s)(VERSION=169869568))",cmd,pass);


  119.          slen = build_packet(buf, command);


  122.          fprintf(stdout, "send command: %s\n\n", command);
  123.          rlen =send(sock, buf, slen,0);


  126.          fprintf(stdout, "begin recv\n");
  127.          

  129.          rlen = ora_recv(sock, buf, &packlen);
  130.          char * p=buf ;

  132.          packlen = packlen < rlen ?packlen:rlen ;
  133.          if  (buf[4] ==4 ) {

  135.                  write_func(&p[12], packlen - 12 ,1, stdout);
  136.                  write_func("\n", 1,1,stdout);
  137.                  return 0;
  138.          }



  142.          send(sock, "\n",1,0);



  146.          while ((rlen = ora_recv(sock, p, &packlen))  >0) {
  147.                 /*this line for  raise  error  some times */
  148.            //                 packlen = packlen < rlen ?packlen:rlen ;
  149.                  write_func(&p[10],  rlen -10  ,1, stdout);
  150.          }

  152.          write_func("\n", 1,1, stdout);

  154.          return 0;
  155. }



  159. extern char *optarg;


  162. int main(int argc, char *argv[])
  163. {
  164.          char *host = NULL;
  165.          char *cmd  = NULL;
  166.          char *pass = NULL;
  167.          int port = 1521 ;


  170.          int flags, opt;
  171.          int nsecs, tfnd;


  174.          if (argc >1 && argv[1][0] == '-') {
  175.                  cmd = "ping";
  176.          }else {
  177.                  cmd = argv[1] ;
  178.          }

  180.          
  181.          

  183.          nsecs = 0;
  184.          tfnd = 0;
  185.          flags = 0;
  186.          while ((opt = getopt(argc, argv, "dih:p:")) != -1) {
  187.                  switch (opt) {
  188.                  case 'h':
  189.                    host = optarg ;
  190.                    break;
  191.                  case 'p':
  192.                    pass = optarg ;
  193.                    break;
  194.                  case 'i':
  195.                    write_func = dump_char_parenify ;
  196.                    break ;
  197.                  case 'd':
  198.                    debug_mode =1 ;
  199.                    break ;
  200.                  default: /* '?' */
  201.                          usage();
  202.                          exit(EXIT_FAILURE);
  203.                  }
  204.          }


  207.          
  208.          if (host ==NULL) {
  209.                  usage();
  210.                  exit(EXIT_FAILURE);

  212.          } ;

  214.          sockstart(wsad);
  215.          int sock = tcp_connect(host, port) ;
  216.          printf("connect to %s:%d\n", host,port);
  217.          if (sock<0) {
  218.                  exit(-1);
  219.          }

  221.          tns_cmd(sock, cmd, pass);
  222.          closesocket(sock) ;
  223.          sockend() ;

  225.          exit (EXIT_SUCCESS);
  226. }




  231. void  usage()
  232. {

  234.   fprintf(stderr, "Usage: tnscmd [command] -h hostname\n\
  235.   where 'command' is something like ping, version, status, etc.\n\
  236.   (default is ping)\n\
  237.        [-p pass] -  the Oracle listener password\n\
  238.        [-r rawcmd command] - build your own CONNECT_DATA string\n\
  239.        [-i]  indent & outdent on parens\n\
  240.        [-d]  debug mode & print hex data \n"  );


  243. }

复制代码


all code:



            阿飛
            2007/11/20

[ 本帖最后由 gangjh 于 2007-11-24 08:42 编辑 ]

tnscmd.tar.gz

14.09 KB, 下载次数: 574

tnscmd.tar.gz
bigmoyo

论坛徽章:
0
2楼 [报告]
发表于 2007-11-20 10:42 |只看该作者

——Ｃ较强嘛

——试试。
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
gangjh

求职 : 数据库管理员
论坛徽章:
0
3楼 [报告]
发表于 2007-11-23 16:40 |只看该作者
稍微作了點修改.
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
managergh

论坛徽章:
0
4楼 [报告]
发表于 2007-11-23 16:48 |只看该作者
一定要试试 ````:em11:
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
xqlb

论坛徽章:
0
5楼 [报告]
发表于 2009-02-06 20:00 |只看该作者
3Q嘿嘿`测试去
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP