Comments (4)
Add MacAddrs.class to the list of ProcProviders in Procs.java.
Originally this used the ServiceLoader system but I believe it has problems in Servlet containers. If there is a way to make ServiceLoader work in all environments we can switch it back. This would allow plugging them in without changing the driver.
Obviously MAC address should be in the driver proper.
Also, remember the name (in your case "macaddr") must match the name in the pg_proc table exactly. If an underscore exists in pg_proc you must add it in the name as well.
from pgjdbc-ng.
Thanks for the input, I managed to get it work. The name must be "macaddr_".
/**
* Copyright (c) 2013, impossibl.com
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* * Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* * Neither the name of impossibl.com nor the names of its contributors may
* be used to endorse or promote products derived from this software
* without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
package com.impossibl.postgres.system.procs;
import com.impossibl.postgres.system.Context;
import com.impossibl.postgres.types.PrimitiveType;
import com.impossibl.postgres.types.Type;
import java.io.IOException;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.jboss.netty.buffer.ChannelBuffer;
public class MacAddrs extends SimpleProcProvider {
// http://git.postgresql.org/gitweb/?p=postgresql.git;a=blob;f=src/include/utils/inet.h;h=3d8e31c31c83d5544ea170144b03b0357cd77b2b;hb=HEAD
// http://git.postgresql.org/gitweb/?p=postgresql.git;a=blob;f=src/backend/utils/adt/mac.c;h=aa9993fa5c6406fa7274ad61de270d5086781a5d;hb=HEAD
public MacAddrs() {
super(new TxtEncoder(), new TxtDecoder(), new BinEncoder(), new BinDecoder(), "macaddr_");
}
static class BinDecoder extends BinaryDecoder {
@Override
public PrimitiveType getInputPrimitiveType() {
return PrimitiveType.Binary;
}
@Override
public Class<?> getOutputType() {
return byte[].class;
}
@Override
public byte[] decode(Type type, ChannelBuffer buffer, Context context) throws IOException {
int length = buffer.readInt();
if (length == -1) {
return null;
}
else if (length != 6) {
throw new IOException("invalid length");
}
byte[] bytes = new byte[6];
buffer.readBytes(bytes);
return bytes;
}
}
static class BinEncoder extends BinaryEncoder {
@Override
public Class<?> getInputType() {
return byte[].class;
}
@Override
public PrimitiveType getOutputPrimitiveType() {
return PrimitiveType.Binary;
}
@Override
public void encode(Type type, ChannelBuffer buffer, Object val, Context context) throws IOException {
if (val == null) {
buffer.writeInt(-1);
}
else {
byte[] bytes = (byte[]) val;
if (bytes.length != 6) {
throw new IOException("invalid length");
}
buffer.writeInt(6);
buffer.writeBytes(bytes);
}
}
}
static class TxtDecoder extends TextDecoder {
/*
* '08:00:2b:01:02:03' '08-00-2b-01-02-03' '08002b:010203' '08002b-010203'
* '0800.2b01.0203' '08002b010203'
*/
private static final Pattern macPattern = Pattern
.compile("([0-9a-f-A-F]{2})[:-]?([0-9a-f-A-F]{2})[-:.]?([0-9a-f-A-F]{2})[:-]?([0-9a-f-A-F]{2})[-:.]?([0-9a-f-A-F]{2})[:-]?([0-9a-f-A-F]{2})");
@Override
public PrimitiveType getInputPrimitiveType() {
return PrimitiveType.Binary;
}
@Override
public Class<?> getOutputType() {
return byte[].class;
}
@Override
public byte[] decode(Type type, CharSequence buffer, Context context) throws IOException {
Matcher m = macPattern.matcher(buffer);
if (!m.matches()) {
throw new IOException("Invalid Mac address: " + buffer);
}
byte[] addr = new byte[6];
for (int i = 0; i < 6; i++) {
addr[i] = (byte) Integer.parseInt(m.group(i + 1), 16);
}
return addr;
}
}
static class TxtEncoder extends TextEncoder {
private static final char[] hexDigits = new char[] {'0', '1', '2', '3', '4', '5', '6', '6', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
private static final char separator = ':';
@Override
public Class<?> getInputType() {
return byte[].class;
}
@Override
public PrimitiveType getOutputPrimitiveType() {
return PrimitiveType.Binary;
}
@Override
public void encode(Type type, StringBuilder buffer, Object val, Context context) throws IOException {
byte[] addr = (byte[]) val;
if (addr.length != 6) {
throw new IOException("invalid length");
}
for (byte b : addr) {
int bi = b & 0xff;
buffer.append(hexDigits[bi >> 4]);
buffer.append(hexDigits[bi & 0xf]).append(separator);
}
buffer.setLength(buffer.length() - 1);
}
}
}
from pgjdbc-ng.
Make a pull request and I'll include it.
from pgjdbc-ng.
Pulled in #36
from pgjdbc-ng.
Related Issues (20)
- Possibility change default schema HOT 2
- ResultSetDelegator for PGStatementDelegator HOT 1
- CryptoUtil.nounce(nounceLength,secureRandom) is too slow in Openshift 4
- Connect timeout with pgjdbc-ng but PostgreSQL JDBC Driver work
- Endlessly recursive error handling (0.8.9)
- Support TCP keepalive and user timeout settings HOT 1
- LEAK: ByteBuf.release() was not called before it's garbage-collected HOT 1
- Support for stringtype=unspecified?
- Avoid use of prepared statement and still use placeholders
- Allow underscore _ in the host name of a postgres database HOT 1
- Issue with RDS IAM Role Authentication
- update protocol properties at the time of connection creation
- What's the status and direction of the project? HOT 17
- Does it support MATCH_RECOGNIZE? HOT 4
- SCRAM channel binding check failed HOT 3
- Connection leak when timing out connection attempts
- Transfer to PostgreSQL Organization HOT 12
- Committer approval for transfer of copyright HOT 29
- Prepared statement already exists
- Parameter Parsing fails on concat operator in SQLText#parse
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from pgjdbc-ng.