Logo Search packages:      
Sourcecode: mysql-connector-java version File versions  Download package

NamedPipeSocketFactory.java

/*
 Copyright (c) 2002, 2011, Oracle and/or its affiliates. All rights reserved.
 

  The MySQL Connector/J is licensed under the terms of the GPLv2
  <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most MySQL Connectors.
  There are special exceptions to the terms and conditions of the GPLv2 as it is applied to
  this software, see the FLOSS License Exception
  <http://www.mysql.com/about/legal/licensing/foss-exception.html>.

  This program is free software; you can redistribute it and/or modify it under the terms
  of the GNU General Public License as published by the Free Software Foundation; version 2
  of the License.

  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  See the GNU General Public License for more details.

  You should have received a copy of the GNU General Public License along with this
  program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth
  Floor, Boston, MA 02110-1301  USA



 */
package com.mysql.jdbc;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.RandomAccessFile;
import java.net.Socket;
import java.net.SocketException;
import java.sql.SQLException;
import java.util.Properties;

/**
 * A socket factory for named pipes (on Windows)
 * 
 * @author Mark Matthews
 */
00042 public class NamedPipeSocketFactory implements SocketFactory, SocketMetadata {
      /**
       * A socket that encapsulates named pipes on Windows
       */
00046       class NamedPipeSocket extends Socket {
            private boolean isClosed = false;

            private RandomAccessFile namedPipeFile;

            NamedPipeSocket(String filePath) throws IOException {
                  if ((filePath == null) || (filePath.length() == 0)) {
                        throw new IOException(Messages
                                    .getString("NamedPipeSocketFactory.4")); //$NON-NLS-1$
                  }

                  this.namedPipeFile = new RandomAccessFile(filePath, "rw"); //$NON-NLS-1$
            }

            /**
             * @see java.net.Socket#close()
             */
00063             public synchronized void close() throws IOException {
                  this.namedPipeFile.close();
                  this.isClosed = true;
            }

            /**
             * @see java.net.Socket#getInputStream()
             */
00071             public InputStream getInputStream() throws IOException {
                  return new RandomAccessFileInputStream(this.namedPipeFile);
            }

            /**
             * @see java.net.Socket#getOutputStream()
             */
00078             public OutputStream getOutputStream() throws IOException {
                  return new RandomAccessFileOutputStream(this.namedPipeFile);
            }

            /**
             * @see java.net.Socket#isClosed()
             */
00085             public boolean isClosed() {
                  return this.isClosed;
            }
      }

      /**
       * Enables OutputStream-type functionality for a RandomAccessFile
       */
00093       class RandomAccessFileInputStream extends InputStream {
            RandomAccessFile raFile;

            RandomAccessFileInputStream(RandomAccessFile file) {
                  this.raFile = file;
            }

            /**
             * @see java.io.InputStream#available()
             */
00103             public int available() throws IOException {
                  return -1;
            }

            /**
             * @see java.io.InputStream#close()
             */
00110             public void close() throws IOException {
                  this.raFile.close();
            }

            /**
             * @see java.io.InputStream#read()
             */
00117             public int read() throws IOException {
                  return this.raFile.read();
            }

            /**
             * @see java.io.InputStream#read(byte[])
             */
00124             public int read(byte[] b) throws IOException {
                  return this.raFile.read(b);
            }

            /**
             * @see java.io.InputStream#read(byte[], int, int)
             */
00131             public int read(byte[] b, int off, int len) throws IOException {
                  return this.raFile.read(b, off, len);
            }
      }

      /**
       * Enables OutputStream-type functionality for a RandomAccessFile
       */
00139       class RandomAccessFileOutputStream extends OutputStream {
            RandomAccessFile raFile;

            RandomAccessFileOutputStream(RandomAccessFile file) {
                  this.raFile = file;
            }

            /**
             * @see java.io.OutputStream#close()
             */
00149             public void close() throws IOException {
                  this.raFile.close();
            }

            /**
             * @see java.io.OutputStream#write(byte[])
             */
00156             public void write(byte[] b) throws IOException {
                  this.raFile.write(b);
            }

            /**
             * @see java.io.OutputStream#write(byte[], int, int)
             */
00163             public void write(byte[] b, int off, int len) throws IOException {
                  this.raFile.write(b, off, len);
            }

            /**
             * @see java.io.OutputStream#write(int)
             */
00170             public void write(int b) throws IOException {
            }
      }

      public static final String NAMED_PIPE_PROP_NAME = "namedPipePath"; //$NON-NLS-1$

      private Socket namedPipeSocket;

      /**
       * Constructor for NamedPipeSocketFactory.
       */
00181       public NamedPipeSocketFactory() {
            super();
      }

      /**
       * @see com.mysql.jdbc.SocketFactory#afterHandshake()
       */
00188       public Socket afterHandshake() throws SocketException, IOException {
            return this.namedPipeSocket;
      }

      /**
       * @see com.mysql.jdbc.SocketFactory#beforeHandshake()
       */
00195       public Socket beforeHandshake() throws SocketException, IOException {
            return this.namedPipeSocket;
      }

      /**
       * @see com.mysql.jdbc.SocketFactory#connect(String, Properties)
       */
00202       public Socket connect(String host, int portNumber /* ignored */,
                  Properties props) throws SocketException, IOException {
            String namedPipePath = props.getProperty(NAMED_PIPE_PROP_NAME);

            if (namedPipePath == null) {
                  namedPipePath = "\\\\.\\pipe\\MySQL"; //$NON-NLS-1$
            } else if (namedPipePath.length() == 0) {
                  throw new SocketException(Messages
                              .getString("NamedPipeSocketFactory.2") //$NON-NLS-1$
                              + NAMED_PIPE_PROP_NAME
                              + Messages.getString("NamedPipeSocketFactory.3")); //$NON-NLS-1$
            }

            this.namedPipeSocket = new NamedPipeSocket(namedPipePath);

            return this.namedPipeSocket;
      }

      public boolean isLocallyConnected(ConnectionImpl conn) throws SQLException {
            // Until I learn otherwise (or learn how to detect it), I assume that we are
            return true;
      }
}

Generated by  Doxygen 1.6.0   Back to index