home *** CD-ROM | disk | FTP | other *** search
/ PC World Komputer 1996 February / PCWK0296.iso / po7_win / object10 / oadvise.cpp < prev    next >
Encoding:
C/C++ Source or Header  |  1994-12-21  |  8.9 KB  |  388 lines
  1. /* Copyright (c) Oracle Corporation 1994.  All Rights Reserved */
  2.  
  3. /*
  4.     This source code is provided as a debugging aid for developers
  5.     who have purchased Oracle Objects for OLE.       Please see the
  6.     online help for documentation of these classes.
  7. */
  8.  
  9. /*
  10.     Oracle Objects for OLE     C++ Classes
  11.     
  12.     This file implements the OAdvise class
  13.                            
  14.     CREATED    ********   11/22/94
  15.  
  16. */
  17.  
  18. #include "windows.h"
  19. #include <ole2.h>
  20. #include <olenls.h>       
  21. #include <dispatch.h>  
  22.  
  23. #ifndef ORACL_ORACLE
  24. #include "oracl.h"
  25. #endif
  26.  
  27. #ifndef _OracleInProcServer_H_
  28. #include <oratlb.h>
  29. #endif
  30.  
  31. static const IID IID_IOraAdvisorySink =
  32. {0xab598600, 0x0a9a, 0x101b, { 0xad, 0xf2, 0x04, 0x02, 0x1c, 0x00, 0x70, 0x02 } };
  33.  
  34. // ----- OOLEAdvise -----------------------------------------------
  35.  
  36. class OOLEAdvise : public IOraAdvisorySink
  37. { 
  38. public:
  39.     // construction & destruction
  40.     OOLEAdvise(OAdvise *parent = NULL);
  41.     ~OOLEAdvise(void);
  42.  
  43.     // IUnknown overrides
  44.     STDMETHODIMP         QueryInterface(REFIID, void **);
  45.     STDMETHODIMP_(ULONG) AddRef(void);
  46.     STDMETHODIMP_(ULONG) Release(void);
  47.     
  48.     // our entries
  49.     STDMETHODIMP         OnActionRequest(int action);
  50.     STDMETHODIMP         OnAction(int action);
  51.     STDMETHODIMP         OnStatusChange(int action);
  52.         
  53. private:
  54.     unsigned long  refcount;
  55.     OAdvise       *m_parent;
  56. };
  57.  
  58. // ----- OAdvise -----------------------------------------------
  59.  
  60. OAdvise::OAdvise(void)
  61. {
  62. }
  63.  
  64. OAdvise::OAdvise(const OAdvise &other)
  65. {
  66.     Copy(other);
  67. }
  68.  
  69. OAdvise::OAdvise(const ODynaset &dyn)
  70. {
  71.     OAdvise(); // default contructor
  72.     Open(dyn);
  73. }
  74.  
  75. OAdvise::~OAdvise(void)
  76. {
  77.     Cleanup();
  78. }
  79.  
  80. oresult OAdvise::Cleanup(void)
  81. {
  82.     if (IsOpen())
  83.     {
  84.         // disconnect from dynaset
  85.         m_oDyn.ErrorReset();
  86.         ((_IOraDynaset *) (m_oDyn.Internal()))->DUnadvise((OOLEAdvise *) Internal());
  87.         if (0 != m_oDyn.ErrorNumber())
  88.         { // error in unadvise
  89.             SetOtherError(m_oDyn.Internal());
  90.             return(OFAILURE);
  91.         }        
  92.     }
  93.     
  94.     // close the dynaset
  95.     m_oDyn.Close();
  96.     
  97.     return(OOracleObject::Cleanup());
  98. }
  99.  
  100. oresult OAdvise::Copy(const OAdvise &other)
  101. {
  102.     m_oDyn = other.m_oDyn;
  103.     
  104.     // we can't just copy the oipadv (and AddRef) here.  That wouldn't get the
  105.     //   callbacks to our object.  We've got to create a new OOLEAdvise.
  106.     
  107.     OOLEAdvise *tempadv = new OOLEAdvise(this);
  108.     if (!tempadv)
  109.     { // couldn't get memory?
  110.         SetInternalError(OERROR_MEMORY);
  111.         return(OFAILURE);
  112.     }
  113.     
  114.     if (SetObjectInterface((void *) tempadv, FALSE) != OSUCCESS)
  115.         return(OFAILURE);
  116.     
  117.     // tell dynaset about it
  118.     m_oDyn.ErrorReset();
  119.     ((_IOraDynaset *) (m_oDyn.Internal()))->DAdvise(tempadv);
  120.     if (0 != m_oDyn.ErrorNumber())
  121.     { // failure at dynaset
  122.         SetOtherError(m_oDyn.Internal());
  123.         return(OFAILURE);
  124.     }
  125.     
  126.     // everything worked
  127.     return(OSUCCESS);
  128. }
  129.  
  130. oresult OAdvise::Open(const ODynaset &odyn)
  131. {
  132.     if (!odyn.IsOpen())
  133.     {
  134.         SetInternalError(OERROR_INVPARENT); 
  135.         return(OFAILURE);
  136.     }
  137.     
  138.     // create new advisory object
  139.     OOLEAdvise *tempadv = new OOLEAdvise(this);
  140.     if (!tempadv)
  141.     { // couldn't get memory?
  142.         SetInternalError(OERROR_MEMORY);
  143.         return(OFAILURE);
  144.     }
  145.     SetObjectInterface((void *) tempadv, FALSE);
  146.     
  147.     // get a copy of dynaset we're connected to
  148.     m_oDyn = odyn;
  149.     
  150.     // tell dynaset about it
  151.     m_oDyn.ErrorReset();
  152.     ((_IOraDynaset *) (m_oDyn.Internal()))->DAdvise(tempadv);
  153.     if (0 != m_oDyn.ErrorNumber())
  154.     { // failure at dynaset
  155.         SetOtherError(m_oDyn.Internal());
  156.         return(OFAILURE);
  157.     }
  158.     
  159.     // everything worked
  160.     return(OSUCCESS);
  161. }
  162.  
  163. ODynaset OAdvise::GetDynaset(void) const
  164. {
  165.     ActionGetStart(&m_oDyn); // set errors (if needed)
  166.     
  167.     return(m_oDyn);
  168. }
  169.  
  170. oresult OAdvise::Close(void)
  171. {
  172.     return(Cleanup());
  173. }
  174.  
  175. // overloaded assignment operator
  176. OAdvise &OAdvise::operator=(const OAdvise &other)
  177. {
  178.     if (&other == this)
  179.         return(*this); // self assignment - do nothing
  180.     
  181.     // clear out our old state
  182.     if (OSUCCESS == Cleanup())
  183.     {
  184.         Copy(other); // call copy constructor
  185.     }
  186.     // if the cleanup failed (possible but unlikely) we don't do the copy
  187.     //    and as a result, we pass on the unmodified (or partly cleaned!) object
  188.     
  189.     return(*this);
  190. } 
  191.  
  192. oboolean OAdvise::ActionRequest(int movekind)
  193. {
  194.     return(TRUE);
  195. }
  196.  
  197. void OAdvise::ActionNotify(int movekind)
  198. {
  199.     return;
  200. }
  201.  
  202. void OAdvise::StatusChange(int statuskind)
  203. {
  204.     return;
  205. }
  206.  
  207. // messages that oipsrv hands us on advises
  208. #define OIPMSG_BOOKMARK         18
  209. #define OIPMSG_MOVEFIRST          64
  210. #define OIPMSG_MOVENEXT          65
  211. #define OIPMSG_MOVEPREV          66
  212. #define OIPMSG_MOVELAST          67
  213. #define OIPMSG_FINDFIRST          68
  214. #define OIPMSG_FINDNEXT          69
  215. #define OIPMSG_FINDPREV          70
  216. #define OIPMSG_FINDLAST          71
  217. #define OIPMSG_DELETE          72
  218. #define OIPMSG_ADDNEW          73
  219. #define OIPMSG_REFRESH          74
  220. #define OIPMSG_ROLLBACK          76
  221. #define OIPMSG_CLOSE          77
  222. #define OIPMSG_DATAFIELDCHANGED 78
  223. #define OIPMSG_SAVEDATA          79
  224. #define OIPMSG_READDATA          80
  225. #define OIPMSG_UPDATE          81
  226. #define OIPMSG_UNLOAD          82
  227.  
  228. // ----- OOLEAdvise -----------------------------------------------
  229.  
  230. OOLEAdvise::OOLEAdvise(OAdvise *parent) 
  231. { 
  232.     refcount = 1;
  233.     m_parent = parent;
  234. } 
  235.  
  236.  
  237. OOLEAdvise::~OOLEAdvise() 
  238. { 
  239. } 
  240.  
  241. STDMETHODIMP_(ULONG) 
  242. OOLEAdvise::AddRef() 
  243. { 
  244.     return ++refcount; 
  245. } 
  246.  
  247. STDMETHODIMP_(ULONG) 
  248. OOLEAdvise::Release() 
  249. { 
  250.     if (--refcount == 0) 
  251.       { 
  252.         delete this; 
  253.         return 0; 
  254.       } 
  255.  
  256.     return refcount; 
  257. } 
  258.  
  259. STDMETHODIMP 
  260. OOLEAdvise::QueryInterface(REFIID iid, void **ppv) 
  261. {
  262.     if (!IsEqualGUID(iid, IID_IUnknown) && !IsEqualGUID(iid, IID_IOraAdvisorySink)) 
  263.         return ResultFromScode(E_NOINTERFACE);  // unsupported interface
  264.     
  265.     // caller is asking for us
  266.     *ppv = this; 
  267.     AddRef(); 
  268.  
  269.     return NOERROR; 
  270. } 
  271.  
  272. STDMETHODIMP 
  273. OOLEAdvise::OnActionRequest(int action) 
  274. {
  275.     oboolean result;
  276.     int message;  // message we pass
  277.     
  278.     if (!m_parent)
  279.         return(ResultFromScode(S_OK));  // we aren't been bound, so OK request
  280.     
  281.     // translate action
  282.     switch(action)
  283.     {
  284.     case OIPMSG_MOVEFIRST:
  285.         message = OADVISE_MOVE_FIRST;
  286.         break;
  287.     case OIPMSG_MOVEPREV:
  288.          message = OADVISE_MOVE_PREV;
  289.         break;
  290.     case OIPMSG_MOVENEXT:
  291.         message = OADVISE_MOVE_NEXT;
  292.         break;
  293.     case OIPMSG_MOVELAST:
  294.         message = OADVISE_MOVE_LAST;
  295.         break;
  296.     case OIPMSG_BOOKMARK:
  297.         message = OADVISE_MOVE_TOMARK;
  298.         break; 
  299.     case OIPMSG_DELETE:
  300.         message = OADVISE_DELETE;
  301.         break;
  302.     case OIPMSG_ADDNEW:
  303.         message = OADVISE_ADDNEW;
  304.         break;
  305.     case OIPMSG_UPDATE:
  306.         message = OADVISE_UPDATE;
  307.         break;
  308.     case OIPMSG_REFRESH:
  309.         message = OADVISE_REFRESH;
  310.         break;
  311.     case OIPMSG_ROLLBACK:
  312.         message = OADVISE_ROLLBACK;
  313.         break;
  314.     default:
  315.         message = OADVISE_OTHER;
  316.         break;
  317.     }
  318.     
  319.     result = m_parent->ActionRequest(message);
  320.     
  321.     return(result ? ResultFromScode(S_OK) : ResultFromScode(S_FALSE));
  322. } 
  323.  
  324. STDMETHODIMP 
  325. OOLEAdvise::OnAction(int action) 
  326. {
  327.     int message;  // message we pass
  328.     
  329.     if (!m_parent)
  330.         return(ResultFromScode(S_OK));  // we aren't been bound, so OK request
  331.     
  332.     switch(action)
  333.     {
  334.     case OIPMSG_MOVEFIRST:
  335.         message = OADVISE_MOVE_FIRST;
  336.         break;
  337.     case OIPMSG_MOVEPREV:
  338.         message = OADVISE_MOVE_PREV;
  339.         break;
  340.     case OIPMSG_MOVENEXT:
  341.         message = OADVISE_MOVE_NEXT;
  342.         break;
  343.     case OIPMSG_MOVELAST:
  344.         message = OADVISE_MOVE_LAST;
  345.         break;
  346.     case OIPMSG_BOOKMARK:
  347.         message = OADVISE_MOVE_TOMARK;
  348.         break; 
  349.     case OIPMSG_DELETE:
  350.         message = OADVISE_DELETE;
  351.         break;
  352.     case OIPMSG_ADDNEW:
  353.         message = OADVISE_ADDNEW;
  354.         break;
  355.     case OIPMSG_UPDATE:
  356.         message = OADVISE_UPDATE;
  357.         break;
  358.     case OIPMSG_REFRESH:
  359.         message = OADVISE_REFRESH;
  360.         break;
  361.     case OIPMSG_ROLLBACK:
  362.         message = OADVISE_ROLLBACK;
  363.         break;
  364.     default:
  365.         message = OADVISE_OTHER;
  366.         break;
  367.     }
  368.     
  369.     m_parent->ActionNotify(message);
  370.     
  371.     
  372.     return(ResultFromScode(S_OK));
  373. } 
  374.  
  375.  
  376. /* DCAdvisory::OnStatusChange ------------------------------------------ 
  377.  
  378.    Informs the advisory objects of a variety of status changes. 
  379. --------------------------------------------------------------------- */ 
  380.  
  381. STDMETHODIMP
  382. OOLEAdvise::OnStatusChange(int statCode) 
  383. {
  384.     if (statCode == 1) // DCSTAT_LASTKNOWN is 1, so far as I can tell
  385.         m_parent->StatusChange(OADVISE_FOUNDLAST);
  386.     return NOERROR; 
  387. } 
  388.